JdbcStreamingActionContext

class JdbcStreamingActionContext extends BasicStreamingActionContext with JdbcActionContext

Source: JdbcBackend.scala

Linear Supertypes

JdbcActionContext, JdbcBackend.BasicStreamingActionContext, Subscription, StreamingActionContext, JdbcBackend.BasicActionContext, ActionContext, AnyRef, Any

Type Hierarchy

Ordering

Alphabetic
By Inheritance

Inherited

JdbcStreamingActionContext
JdbcActionContext
BasicStreamingActionContext
Subscription
StreamingActionContext
BasicActionContext
ActionContext
AnyRef
Any

Implicitly

by any2stringadd
by StringFormat
by Ensuring
by ArrowAssoc

Hide All
Show All

Visibility

Public
Protected

Instance Constructors

new JdbcStreamingActionContext(subscriber: Subscriber[_], useSameThread: Boolean, database: Database, bufferNext: Boolean)

Value Members

final def !=(arg0: Any): Boolean
Definition Classes
AnyRef → Any
final def ##: Int
Definition Classes
AnyRef → Any
def +(other: String): String
Implicit
This member is added by an implicit conversion from JdbcStreamingActionContext toany2stringadd[JdbcStreamingActionContext] performed by method any2stringadd in scala.Predef.
Definition Classes
any2stringadd
def ->[B](y: B): (JdbcStreamingActionContext, B)
Implicit
This member is added by an implicit conversion from JdbcStreamingActionContext toArrowAssoc[JdbcStreamingActionContext] performed by method ArrowAssoc in scala.Predef.
Definition Classes
ArrowAssoc
Annotations
@inline()
final def ==(arg0: Any): Boolean
Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0
Definition Classes
Any
val bufferNext: Boolean
def cancel(): Unit
Definition Classes
BasicStreamingActionContext → Subscription
def cancelled: Boolean
Whether the stream has been cancelled by the Subscriber
Whether the stream has been cancelled by the Subscriber
Definition Classes
BasicStreamingActionContext
def clone(): AnyRef
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
def connection: Connection
The current JDBC Connection
The current JDBC Connection
Definition Classes
JdbcActionContext
def delivered(num: Long): Long
Indicate that the specified number of elements has been delivered.
Indicate that the specified number of elements has been delivered. Returns the remaining demand. This is an atomic operation. It must only be called from the synchronous action context which performs the streaming.
Definition Classes
BasicStreamingActionContext
def demandBatch: Long
Get the current demand that has not yet been marked as delivered and mark it as being in the current batch.
Get the current demand that has not yet been marked as delivered and mark it as being in the current batch. When this value is negative, the initial streaming action is still running and the real demand can be computed by subtracting Long.MinValue from the returned value.
Definition Classes
BasicStreamingActionContext
def emit(v: Any): Unit
Emit a single result of the stream.
Emit a single result of the stream. Any Exception thrown by this method should be passed on to the caller.
Definition Classes
BasicStreamingActionContext → StreamingActionContext
def ensuring(cond: (JdbcStreamingActionContext) => Boolean, msg: => Any): JdbcStreamingActionContext
Implicit
This member is added by an implicit conversion from JdbcStreamingActionContext toEnsuring[JdbcStreamingActionContext] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: (JdbcStreamingActionContext) => Boolean): JdbcStreamingActionContext
Implicit
This member is added by an implicit conversion from JdbcStreamingActionContext toEnsuring[JdbcStreamingActionContext] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: Boolean, msg: => Any): JdbcStreamingActionContext
Implicit
This member is added by an implicit conversion from JdbcStreamingActionContext toEnsuring[JdbcStreamingActionContext] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: Boolean): JdbcStreamingActionContext
Implicit
This member is added by an implicit conversion from JdbcStreamingActionContext toEnsuring[JdbcStreamingActionContext] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
final def eq(arg0: AnyRef): Boolean
Definition Classes
AnyRef
def equals(arg0: AnyRef): Boolean
Definition Classes
AnyRef → Any
final def getClass(): Class[_ <: AnyRef]
Definition Classes
AnyRef → Any
Annotations
@native() @HotSpotIntrinsicCandidate()
def hashCode(): Int
Definition Classes
AnyRef → Any
Annotations
@native() @HotSpotIntrinsicCandidate()
final def isInstanceOf[T0]: Boolean
Definition Classes
Any
final def isPinned: Boolean
Check if the session is pinned.
Check if the session is pinned. May only be called from a synchronous action context.
Definition Classes
ActionContext
final def ne(arg0: AnyRef): Boolean
Definition Classes
AnyRef
final def notify(): Unit
Definition Classes
AnyRef
Annotations
@native() @HotSpotIntrinsicCandidate()
final def notifyAll(): Unit
Definition Classes
AnyRef
Annotations
@native() @HotSpotIntrinsicCandidate()
final def pin: Unit
Pin the current session.
Pin the current session. Multiple calls to pin may be nested. The same number of calls to unpin is required in order to mark the session as not pinned anymore. A pinned session will not be released at the end of a primitive database action. Instead, the same pinned session is passed to all subsequent actions until it is unpinned. Note that pinning does not force an actual database connection to be opened. This still happens on demand. May only be called from a synchronous action context.
Definition Classes
ActionContext
def popStatementParameters: Unit
Definition Classes
JdbcActionContext
def pushStatementParameters(p: StatementParameters): Unit
Definition Classes
JdbcActionContext
def request(l: Long): Unit
Definition Classes
BasicStreamingActionContext → Subscription
def restartStreaming: Unit
Restart a suspended streaming action.
Restart a suspended streaming action. Must only be called from the Subscriber context.
Definition Classes
BasicStreamingActionContext
def session: Session
Definition Classes
JdbcActionContext → BasicActionContext
val streamingResultPromise: Promise[Null]
The Promise to complete when streaming has finished.
The Promise to complete when streaming has finished.
Definition Classes
BasicStreamingActionContext
def subscription: JdbcBackend.BasicStreamingActionContext
Get the Subscription for this stream.
Get the Subscription for this stream.
Definition Classes
BasicStreamingActionContext → StreamingActionContext
final def synchronized[T0](arg0: => T0): T0
Definition Classes
AnyRef
def toString(): String
Definition Classes
AnyRef → Any
def tryOnComplete: Unit
Finish the stream with onComplete if it is not finished yet.
Finish the stream with onComplete if it is not finished yet. May only be called from a synchronous action context.
Definition Classes
BasicStreamingActionContext
def tryOnError(t: Throwable): Unit
Finish the stream with onError if it is not finished yet.
Finish the stream with onError if it is not finished yet. May only be called from a synchronous action context.
Definition Classes
BasicStreamingActionContext
final def unpin: Unit
Unpin this session once.
Unpin this session once. May only be called from a synchronous action context.
Definition Classes
ActionContext
val useSameThread: Boolean
Whether to run all operations on the current thread or schedule them normally on the appropriate ExecutionContext.
Whether to run all operations on the current thread or schedule them normally on the appropriate ExecutionContext. This is used by the blocking API.
Attributes
protected[BasicBackend]
Definition Classes
BasicStreamingActionContext → BasicActionContext
final def wait(arg0: Long, arg1: Int): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(arg0: Long): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException]) @native()
final def wait(): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])

Inherited from JdbcActionContext

Value Members

def connection: Connection
The current JDBC Connection
The current JDBC Connection
Definition Classes
JdbcActionContext
def popStatementParameters: Unit
Definition Classes
JdbcActionContext
def pushStatementParameters(p: StatementParameters): Unit
Definition Classes
JdbcActionContext
def session: Session
Definition Classes
JdbcActionContext → BasicActionContext

Inherited from JdbcBackend.BasicStreamingActionContext

Value Members

def cancel(): Unit
Definition Classes
BasicStreamingActionContext → Subscription
def cancelled: Boolean
Whether the stream has been cancelled by the Subscriber
Whether the stream has been cancelled by the Subscriber
Definition Classes
BasicStreamingActionContext
def delivered(num: Long): Long
Indicate that the specified number of elements has been delivered.
Indicate that the specified number of elements has been delivered. Returns the remaining demand. This is an atomic operation. It must only be called from the synchronous action context which performs the streaming.
Definition Classes
BasicStreamingActionContext
def demandBatch: Long
Get the current demand that has not yet been marked as delivered and mark it as being in the current batch.
Get the current demand that has not yet been marked as delivered and mark it as being in the current batch. When this value is negative, the initial streaming action is still running and the real demand can be computed by subtracting Long.MinValue from the returned value.
Definition Classes
BasicStreamingActionContext
def emit(v: Any): Unit
Emit a single result of the stream.
Emit a single result of the stream. Any Exception thrown by this method should be passed on to the caller.
Definition Classes
BasicStreamingActionContext → StreamingActionContext
def request(l: Long): Unit
Definition Classes
BasicStreamingActionContext → Subscription
def restartStreaming: Unit
Restart a suspended streaming action.
Restart a suspended streaming action. Must only be called from the Subscriber context.
Definition Classes
BasicStreamingActionContext
val streamingResultPromise: Promise[Null]
The Promise to complete when streaming has finished.
The Promise to complete when streaming has finished.
Definition Classes
BasicStreamingActionContext
def subscription: JdbcBackend.BasicStreamingActionContext
Get the Subscription for this stream.
Get the Subscription for this stream.
Definition Classes
BasicStreamingActionContext → StreamingActionContext
def tryOnComplete: Unit
Finish the stream with onComplete if it is not finished yet.
Finish the stream with onComplete if it is not finished yet. May only be called from a synchronous action context.
Definition Classes
BasicStreamingActionContext
def tryOnError(t: Throwable): Unit
Finish the stream with onError if it is not finished yet.
Finish the stream with onError if it is not finished yet. May only be called from a synchronous action context.
Definition Classes
BasicStreamingActionContext
val useSameThread: Boolean
Whether to run all operations on the current thread or schedule them normally on the appropriate ExecutionContext.
Whether to run all operations on the current thread or schedule them normally on the appropriate ExecutionContext. This is used by the blocking API.
Attributes
protected[BasicBackend]
Definition Classes
BasicStreamingActionContext → BasicActionContext

Inherited from ActionContext

Value Members

final def isPinned: Boolean
Check if the session is pinned.
Check if the session is pinned. May only be called from a synchronous action context.
Definition Classes
ActionContext
final def pin: Unit
Pin the current session.
Pin the current session. Multiple calls to pin may be nested. The same number of calls to unpin is required in order to mark the session as not pinned anymore. A pinned session will not be released at the end of a primitive database action. Instead, the same pinned session is passed to all subsequent actions until it is unpinned. Note that pinning does not force an actual database connection to be opened. This still happens on demand. May only be called from a synchronous action context.
Definition Classes
ActionContext
final def unpin: Unit
Unpin this session once.
Unpin this session once. May only be called from a synchronous action context.
Definition Classes
ActionContext

Inherited from AnyRef

Value Members

final def !=(arg0: Any): Boolean
Definition Classes
AnyRef → Any
final def ##: Int
Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean
Definition Classes
AnyRef → Any
def clone(): AnyRef
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
final def eq(arg0: AnyRef): Boolean
Definition Classes
AnyRef
def equals(arg0: AnyRef): Boolean
Definition Classes
AnyRef → Any
final def getClass(): Class[_ <: AnyRef]
Definition Classes
AnyRef → Any
Annotations
@native() @HotSpotIntrinsicCandidate()
def hashCode(): Int
Definition Classes
AnyRef → Any
Annotations
@native() @HotSpotIntrinsicCandidate()
final def ne(arg0: AnyRef): Boolean
Definition Classes
AnyRef
final def notify(): Unit
Definition Classes
AnyRef
Annotations
@native() @HotSpotIntrinsicCandidate()
final def notifyAll(): Unit
Definition Classes
AnyRef
Annotations
@native() @HotSpotIntrinsicCandidate()
final def synchronized[T0](arg0: => T0): T0
Definition Classes
AnyRef
def toString(): String
Definition Classes
AnyRef → Any
final def wait(arg0: Long, arg1: Int): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(arg0: Long): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException]) @native()
final def wait(): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
def finalize(): Unit
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.Throwable]) @Deprecated
Deprecated

Inherited from Any

Value Members

final def asInstanceOf[T0]: T0
Definition Classes
Any
final def isInstanceOf[T0]: Boolean
Definition Classes
Any

Inherited by implicit conversion any2stringadd fromJdbcStreamingActionContext to any2stringadd[JdbcStreamingActionContext]

Value Members

def +(other: String): String
Implicit
This member is added by an implicit conversion from JdbcStreamingActionContext toany2stringadd[JdbcStreamingActionContext] performed by method any2stringadd in scala.Predef.
Definition Classes
any2stringadd

Inherited by implicit conversion StringFormat fromJdbcStreamingActionContext to StringFormat[JdbcStreamingActionContext]

Value Members

def formatted(fmtstr: String): String
Implicit
This member is added by an implicit conversion from JdbcStreamingActionContext toStringFormat[JdbcStreamingActionContext] performed by method StringFormat in scala.Predef.
Definition Classes
StringFormat
Annotations
@deprecated @inline()
Deprecated
(Since version 2.12.16) Use formatString.format(value) instead of value.formatted(formatString), or use the f"" string interpolator. In Java 15 and later, formatted resolves to the new method in String which has reversed parameters.

Inherited by implicit conversion Ensuring fromJdbcStreamingActionContext to Ensuring[JdbcStreamingActionContext]

Value Members

def ensuring(cond: (JdbcStreamingActionContext) => Boolean, msg: => Any): JdbcStreamingActionContext
Implicit
This member is added by an implicit conversion from JdbcStreamingActionContext toEnsuring[JdbcStreamingActionContext] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: (JdbcStreamingActionContext) => Boolean): JdbcStreamingActionContext
Implicit
This member is added by an implicit conversion from JdbcStreamingActionContext toEnsuring[JdbcStreamingActionContext] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: Boolean, msg: => Any): JdbcStreamingActionContext
Implicit
This member is added by an implicit conversion from JdbcStreamingActionContext toEnsuring[JdbcStreamingActionContext] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: Boolean): JdbcStreamingActionContext
Implicit
This member is added by an implicit conversion from JdbcStreamingActionContext toEnsuring[JdbcStreamingActionContext] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring

Inherited by implicit conversion ArrowAssoc fromJdbcStreamingActionContext to ArrowAssoc[JdbcStreamingActionContext]

Value Members

def ->[B](y: B): (JdbcStreamingActionContext, B)
Implicit
This member is added by an implicit conversion from JdbcStreamingActionContext toArrowAssoc[JdbcStreamingActionContext] performed by method ArrowAssoc in scala.Predef.
Definition Classes
ArrowAssoc
Annotations
@inline()
def →[B](y: B): (JdbcStreamingActionContext, B)
Implicit
This member is added by an implicit conversion from JdbcStreamingActionContext toArrowAssoc[JdbcStreamingActionContext] performed by method ArrowAssoc in scala.Predef.
Definition Classes
ArrowAssoc
Annotations
@deprecated
Deprecated
(Since version 2.13.0) Use -> instead. If you still wish to display it as one character, consider using a font with programming ligatures such as Fira Code.

Ungrouped

final def !=(arg0: Any): Boolean
Definition Classes
AnyRef → Any
final def ##: Int
Definition Classes
AnyRef → Any
def +(other: String): String
Implicit
This member is added by an implicit conversion from JdbcStreamingActionContext toany2stringadd[JdbcStreamingActionContext] performed by method any2stringadd in scala.Predef.
Definition Classes
any2stringadd
def ->[B](y: B): (JdbcStreamingActionContext, B)
Implicit
This member is added by an implicit conversion from JdbcStreamingActionContext toArrowAssoc[JdbcStreamingActionContext] performed by method ArrowAssoc in scala.Predef.
Definition Classes
ArrowAssoc
Annotations
@inline()
final def ==(arg0: Any): Boolean
Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0
Definition Classes
Any
val bufferNext: Boolean
def cancel(): Unit
Definition Classes
BasicStreamingActionContext → Subscription
def cancelled: Boolean
Whether the stream has been cancelled by the Subscriber
Whether the stream has been cancelled by the Subscriber
Definition Classes
BasicStreamingActionContext
def clone(): AnyRef
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
def connection: Connection
The current JDBC Connection
The current JDBC Connection
Definition Classes
JdbcActionContext
def delivered(num: Long): Long
Indicate that the specified number of elements has been delivered.
Indicate that the specified number of elements has been delivered. Returns the remaining demand. This is an atomic operation. It must only be called from the synchronous action context which performs the streaming.
Definition Classes
BasicStreamingActionContext
def demandBatch: Long
Get the current demand that has not yet been marked as delivered and mark it as being in the current batch.
Get the current demand that has not yet been marked as delivered and mark it as being in the current batch. When this value is negative, the initial streaming action is still running and the real demand can be computed by subtracting Long.MinValue from the returned value.
Definition Classes
BasicStreamingActionContext
def emit(v: Any): Unit
Emit a single result of the stream.
Emit a single result of the stream. Any Exception thrown by this method should be passed on to the caller.
Definition Classes
BasicStreamingActionContext → StreamingActionContext
def ensuring(cond: (JdbcStreamingActionContext) => Boolean, msg: => Any): JdbcStreamingActionContext
Implicit
This member is added by an implicit conversion from JdbcStreamingActionContext toEnsuring[JdbcStreamingActionContext] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: (JdbcStreamingActionContext) => Boolean): JdbcStreamingActionContext
Implicit
This member is added by an implicit conversion from JdbcStreamingActionContext toEnsuring[JdbcStreamingActionContext] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: Boolean, msg: => Any): JdbcStreamingActionContext
Implicit
This member is added by an implicit conversion from JdbcStreamingActionContext toEnsuring[JdbcStreamingActionContext] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: Boolean): JdbcStreamingActionContext
Implicit
This member is added by an implicit conversion from JdbcStreamingActionContext toEnsuring[JdbcStreamingActionContext] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
final def eq(arg0: AnyRef): Boolean
Definition Classes
AnyRef
def equals(arg0: AnyRef): Boolean
Definition Classes
AnyRef → Any
final def getClass(): Class[_ <: AnyRef]
Definition Classes
AnyRef → Any
Annotations
@native() @HotSpotIntrinsicCandidate()
def hashCode(): Int
Definition Classes
AnyRef → Any
Annotations
@native() @HotSpotIntrinsicCandidate()
final def isInstanceOf[T0]: Boolean
Definition Classes
Any
final def isPinned: Boolean
Check if the session is pinned.
Check if the session is pinned. May only be called from a synchronous action context.
Definition Classes
ActionContext
final def ne(arg0: AnyRef): Boolean
Definition Classes
AnyRef
final def notify(): Unit
Definition Classes
AnyRef
Annotations
@native() @HotSpotIntrinsicCandidate()
final def notifyAll(): Unit
Definition Classes
AnyRef
Annotations
@native() @HotSpotIntrinsicCandidate()
final def pin: Unit
Pin the current session.
Pin the current session. Multiple calls to pin may be nested. The same number of calls to unpin is required in order to mark the session as not pinned anymore. A pinned session will not be released at the end of a primitive database action. Instead, the same pinned session is passed to all subsequent actions until it is unpinned. Note that pinning does not force an actual database connection to be opened. This still happens on demand. May only be called from a synchronous action context.
Definition Classes
ActionContext
def popStatementParameters: Unit
Definition Classes
JdbcActionContext
def pushStatementParameters(p: StatementParameters): Unit
Definition Classes
JdbcActionContext
def request(l: Long): Unit
Definition Classes
BasicStreamingActionContext → Subscription
def restartStreaming: Unit
Restart a suspended streaming action.
Restart a suspended streaming action. Must only be called from the Subscriber context.
Definition Classes
BasicStreamingActionContext
def session: Session
Definition Classes
JdbcActionContext → BasicActionContext
val streamingResultPromise: Promise[Null]
The Promise to complete when streaming has finished.
The Promise to complete when streaming has finished.
Definition Classes
BasicStreamingActionContext
def subscription: JdbcBackend.BasicStreamingActionContext
Get the Subscription for this stream.
Get the Subscription for this stream.
Definition Classes
BasicStreamingActionContext → StreamingActionContext
final def synchronized[T0](arg0: => T0): T0
Definition Classes
AnyRef
def toString(): String
Definition Classes
AnyRef → Any
def tryOnComplete: Unit
Finish the stream with onComplete if it is not finished yet.
Finish the stream with onComplete if it is not finished yet. May only be called from a synchronous action context.
Definition Classes
BasicStreamingActionContext
def tryOnError(t: Throwable): Unit
Finish the stream with onError if it is not finished yet.
Finish the stream with onError if it is not finished yet. May only be called from a synchronous action context.
Definition Classes
BasicStreamingActionContext
final def unpin: Unit
Unpin this session once.
Unpin this session once. May only be called from a synchronous action context.
Definition Classes
ActionContext
val useSameThread: Boolean
Whether to run all operations on the current thread or schedule them normally on the appropriate ExecutionContext.
Whether to run all operations on the current thread or schedule them normally on the appropriate ExecutionContext. This is used by the blocking API.
Attributes
protected[BasicBackend]
Definition Classes
BasicStreamingActionContext → BasicActionContext
final def wait(arg0: Long, arg1: Int): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(arg0: Long): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException]) @native()
final def wait(): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
def finalize(): Unit
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.Throwable]) @Deprecated
Deprecated
def formatted(fmtstr: String): String
Implicit
This member is added by an implicit conversion from JdbcStreamingActionContext toStringFormat[JdbcStreamingActionContext] performed by method StringFormat in scala.Predef.
Definition Classes
StringFormat
Annotations
@deprecated @inline()
Deprecated
(Since version 2.12.16) Use formatString.format(value) instead of value.formatted(formatString), or use the f"" string interpolator. In Java 15 and later, formatted resolves to the new method in String which has reversed parameters.
def →[B](y: B): (JdbcStreamingActionContext, B)
Implicit
This member is added by an implicit conversion from JdbcStreamingActionContext toArrowAssoc[JdbcStreamingActionContext] performed by method ArrowAssoc in scala.Predef.
Definition Classes
ArrowAssoc
Annotations
@deprecated
Deprecated
(Since version 2.13.0) Use -> instead. If you still wish to display it as one character, consider using a font with programming ligatures such as Fira Code.

Packages

Scala Language-Integrated Connection Kit

JdbcStreamingActionContext

class JdbcStreamingActionContext extends BasicStreamingActionContext with JdbcActionContext

Instance Constructors

Value Members

Deprecated Value Members

Inherited from JdbcActionContext

Value Members

Inherited from JdbcBackend.BasicStreamingActionContext

Value Members

Inherited from ActionContext

Value Members

Inherited from AnyRef

Value Members

Inherited from Any

Value Members

Inherited by implicit conversion any2stringadd fromJdbcStreamingActionContext to any2stringadd[JdbcStreamingActionContext]

Value Members

Inherited by implicit conversion StringFormat fromJdbcStreamingActionContext to StringFormat[JdbcStreamingActionContext]

Value Members

Inherited by implicit conversion Ensuring fromJdbcStreamingActionContext to Ensuring[JdbcStreamingActionContext]

Value Members

Inherited by implicit conversion ArrowAssoc fromJdbcStreamingActionContext to ArrowAssoc[JdbcStreamingActionContext]

Value Members

Ungrouped

Packages

Scala Language-Integrated Connection Kit

JdbcStreamingActionContext

class JdbcStreamingActionContext extends BasicStreamingActionContext with JdbcActionContext

Instance Constructors

Value Members

Deprecated Value Members

Inherited from JdbcActionContext

Value Members

Inherited from JdbcBackend.BasicStreamingActionContext

Value Members

Inherited from ActionContext

Value Members

Inherited from AnyRef

Value Members

Inherited from Any

Value Members

Inherited by implicit conversion any2stringadd fromJdbcStreamingActionContext to any2stringadd[JdbcStreamingActionContext]

Value Members

Inherited by implicit conversion StringFormat fromJdbcStreamingActionContext to StringFormat[JdbcStreamingActionContext]

Value Members

Inherited by implicit conversion Ensuring fromJdbcStreamingActionContext to Ensuring[JdbcStreamingActionContext]

Value Members

Inherited by implicit conversion ArrowAssoc fromJdbcStreamingActionContext to ArrowAssoc[JdbcStreamingActionContext]

Value Members

Ungrouped

JdbcStreamingActionContext