case class KinesisDataConnector(streamName: String, region: String = "us-east-1", partitionKey: Option[String], partitionKeyIndex: Option[Int], separator: String = ",", name: String, credentialName: Option[String], credential: Option[Credential]) extends StreamingDataConnector with AWSConnector with Product with Serializable
Data Connector implementation that works with Kinesis. Each row produced will be formatted to a string using the separator character provided.
- streamName
The name of the Kinesis stream.
- region
The region containing the Kinesis stream
- partitionKey
The optional static partition key to use
- partitionKeyIndex
The optional field index in the DataFrame row containing the value to use as the partition key
- separator
The field separator to use when formatting the row data
- name
The name of the connector
- credentialName
The optional name of the credential to use when authorizing to the Kinesis stream
- credential
The optional credential to use when authorizing to the Kinesis stream
- Alphabetic
- By Inheritance
- KinesisDataConnector
- Serializable
- Serializable
- Product
- Equals
- AWSConnector
- StreamingDataConnector
- DataConnector
- Connector
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
-
new
KinesisDataConnector(streamName: String, region: String = "us-east-1", partitionKey: Option[String], partitionKeyIndex: Option[Int], separator: String = ",", name: String, credentialName: Option[String], credential: Option[Credential])
- streamName
The name of the Kinesis stream.
- region
The region containing the Kinesis stream
- partitionKey
The optional static partition key to use
- partitionKeyIndex
The optional field index in the DataFrame row containing the value to use as the partition key
- separator
The field separator to use when formatting the row data
- name
The name of the connector
- credentialName
The optional name of the credential to use when authorizing to the Kinesis stream
- credential
The optional credential to use when authorizing to the Kinesis stream
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
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
val
credential: Option[Credential]
- Definition Classes
- KinesisDataConnector → Connector
-
val
credentialName: Option[String]
- Definition Classes
- KinesisDataConnector → Connector
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
getCredential(pipelineContext: PipelineContext): Option[AWSCredential]
- Attributes
- protected
- Definition Classes
- AWSConnector → Connector
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
load(source: Option[String], pipelineContext: PipelineContext, readOptions: DataFrameReaderOptions = DataFrameReaderOptions()): DataFrame
- Definition Classes
- KinesisDataConnector → DataConnector
-
val
name: String
- Definition Classes
- KinesisDataConnector → Connector
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- val partitionKey: Option[String]
- val partitionKeyIndex: Option[Int]
- val region: String
- val separator: String
- val streamName: String
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
def
write(dataFrame: DataFrame, destination: Option[String], pipelineContext: PipelineContext, writeOptions: DataFrameWriterOptions = DataFrameWriterOptions()): Option[StreamingQuery]
- Definition Classes
- KinesisDataConnector → DataConnector