Value Members

1.  final def !=(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

2.  final def ##(): Int

   Definition Classes

   AnyRef → Any

3.  final def ==(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

4.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

5.  val batchingSettings: BatchingSettings
6.  def clone(): AnyRef

   Attributes

   protected[lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... ) @native()

7.  final def eq(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

8.  def equals(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

9.  def finalize(): Unit

   Attributes

   protected[lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( classOf[java.lang.Throwable] )

10.  def generateCredentials(credentials: Option[Map[String, String]]): Option[GoogleCredentials]

    Retrieve the credentials needed to interact with GCP services.

    Retrieve the credentials needed to interact with GCP services.

    credentials

    TA map containing the Google credentials

    returns

    An optional GoogleCredentials object

11.  def generateCredentialsByteArray(credentials: Option[Map[String, String]]): Option[Array[Byte]]

    Given a credentials map, return a byte array

    Given a credentials map, return a byte array

    credentials

    The credentials map

    returns

    A byte array or none

12.  final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

13.  def getCredentialsFromCredentialProvider(credentialProvider: CredentialProvider, credentialName: String = "GCPCredential"): Option[GoogleCredentials]

    Retrieve the credentials needed to interact with GCP services.

    Retrieve the credentials needed to interact with GCP services.

    credentialProvider

    The credential provider

    credentialName

    The name of the credential

    returns

    An optional GoogleCredentials object

14.  def getCredentialsFromPipelineContext(pipelineContext: PipelineContext, credentialName: String = "GCPCredential"): Option[GoogleCredentials]

    Retrieve the credentials needed to interact with GCP services.

    Retrieve the credentials needed to interact with GCP services.

    pipelineContext

    The pipeline context containing the credential provider

    credentialName

    The name of the credential

    returns

    An optional GoogleCredentials object

15.  def getPublisherBuilder(topicName: String, creds: Option[GoogleCredentials]): Builder

    Generates the builder used to create a publisher for Pub/Sub messages.

    Generates the builder used to create a publisher for Pub/Sub messages.

    topicName

    The topic within the Pub/Sub

    creds

    The credentials needed to post the message

16.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

17.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

18.  val messageCountBatchSize: Long
19.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

20.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

21.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

22.  def postMessage(topicName: String, creds: Option[GoogleCredentials], message: String): Boolean

    Write a single message to a PubSub Topic using the provided credentials

    Write a single message to a PubSub Topic using the provided credentials

    topicName

    The topic within the Pub/Sub

    creds

    The credentials needed to post the message

    message

    The message to post to the Pub/Sub topic

    returns

    A boolean indicating whether the message was published

23.  val requestBytesThreshold: Long
24.  val retrySettings: RetrySettings
25.  def setGCSAuthorization(credentials: Map[String, String], pipelineContext: PipelineContext): Unit

    Given a credential map, this function will set the appropriate properties required for Spark access.

    Given a credential map, this function will set the appropriate properties required for Spark access.

    credentials

    The GCP auth map

    pipelineContext

    The current pipeline context

26.  final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes

    AnyRef

27.  def toString(): String

    Definition Classes

    AnyRef → Any

28.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

29.  final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

30.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... ) @native()