Packages

c

com.acxiom.aws.pipeline

KinesisPipelineListener

class KinesisPipelineListener extends SparkListener with EventBasedPipelineListener

Linear Supertypes
EventBasedPipelineListener, SparkPipelineListener, PipelineListener, SparkListener, SparkListenerInterface, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. KinesisPipelineListener
  2. EventBasedPipelineListener
  3. SparkPipelineListener
  4. PipelineListener
  5. SparkListener
  6. SparkListenerInterface
  7. AnyRef
  8. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new KinesisPipelineListener(key: String, credentialName: String, credentialProvider: CredentialProvider, region: String, streamName: String, partitionKey: String)

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. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  6. val credentialName: String
    Definition Classes
    KinesisPipelineListener → EventBasedPipelineListener
  7. val credentialProvider: CredentialProvider
    Definition Classes
    KinesisPipelineListener → EventBasedPipelineListener
  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  10. def executionFinished(pipelines: List[Pipeline], pipelineContext: PipelineContext): Option[PipelineContext]
    Definition Classes
    KinesisPipelineListener → SparkPipelineListener → PipelineListener
  11. def executionStarted(pipelines: List[Pipeline], pipelineContext: PipelineContext): Option[PipelineContext]
    Definition Classes
    KinesisPipelineListener → SparkPipelineListener → PipelineListener
  12. def executionStopped(pipelines: List[Pipeline], pipelineContext: PipelineContext): Unit
    Definition Classes
    KinesisPipelineListener → SparkPipelineListener → PipelineListener
  13. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  14. implicit val formats: Formats
    Definition Classes
    PipelineListener
  15. def generateAuditMessage(event: String, audit: ExecutionAudit): String
    Definition Classes
    EventBasedPipelineListener
  16. def generateExceptionMessage(event: String, exception: PipelineStepException, pipelineContext: PipelineContext): String
    Definition Classes
    EventBasedPipelineListener
  17. def generateExecutionMessage(event: String, pipelines: List[Pipeline]): String
    Definition Classes
    EventBasedPipelineListener
  18. def generatePipelineMessage(event: String, pipeline: Pipeline): String
    Definition Classes
    EventBasedPipelineListener
  19. def generatePipelineStepMessage(event: String, pipeline: Pipeline, step: PipelineStep, pipelineContext: PipelineContext): String
    Definition Classes
    EventBasedPipelineListener
  20. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  21. def getSparkSettingsForAudit(pipelineContext: PipelineContext): Map[String, Any]
    Definition Classes
    SparkPipelineListener
  22. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  23. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  24. val key: String
    Definition Classes
    KinesisPipelineListener → EventBasedPipelineListener
  25. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  26. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  27. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  28. def onApplicationEnd(applicationEnd: SparkListenerApplicationEnd): Unit
    Definition Classes
    SparkListener → SparkListenerInterface
  29. def onApplicationStart(applicationStart: SparkListenerApplicationStart): Unit
    Definition Classes
    SparkListener → SparkListenerInterface
  30. def onBlockManagerAdded(blockManagerAdded: SparkListenerBlockManagerAdded): Unit
    Definition Classes
    SparkListener → SparkListenerInterface
  31. def onBlockManagerRemoved(blockManagerRemoved: SparkListenerBlockManagerRemoved): Unit
    Definition Classes
    SparkListener → SparkListenerInterface
  32. def onBlockUpdated(blockUpdated: SparkListenerBlockUpdated): Unit
    Definition Classes
    SparkListener → SparkListenerInterface
  33. def onEnvironmentUpdate(environmentUpdate: SparkListenerEnvironmentUpdate): Unit
    Definition Classes
    SparkListener → SparkListenerInterface
  34. def onExecutorAdded(executorAdded: SparkListenerExecutorAdded): Unit
    Definition Classes
    SparkListener → SparkListenerInterface
  35. def onExecutorBlacklisted(executorBlacklisted: SparkListenerExecutorBlacklisted): Unit
    Definition Classes
    SparkListener → SparkListenerInterface
  36. def onExecutorBlacklistedForStage(executorBlacklistedForStage: SparkListenerExecutorBlacklistedForStage): Unit
    Definition Classes
    SparkListener → SparkListenerInterface
  37. def onExecutorMetricsUpdate(executorMetricsUpdate: SparkListenerExecutorMetricsUpdate): Unit
    Definition Classes
    SparkListener → SparkListenerInterface
  38. def onExecutorRemoved(executorRemoved: SparkListenerExecutorRemoved): Unit
    Definition Classes
    SparkListener → SparkListenerInterface
  39. def onExecutorUnblacklisted(executorUnblacklisted: SparkListenerExecutorUnblacklisted): Unit
    Definition Classes
    SparkListener → SparkListenerInterface
  40. def onJobEnd(jobEnd: SparkListenerJobEnd): Unit
    Definition Classes
    SparkPipelineListener → SparkListener → SparkListenerInterface
  41. def onJobStart(jobStart: SparkListenerJobStart): Unit
    Definition Classes
    SparkPipelineListener → SparkListener → SparkListenerInterface
  42. def onNodeBlacklisted(nodeBlacklisted: SparkListenerNodeBlacklisted): Unit
    Definition Classes
    SparkListener → SparkListenerInterface
  43. def onNodeBlacklistedForStage(nodeBlacklistedForStage: SparkListenerNodeBlacklistedForStage): Unit
    Definition Classes
    SparkListener → SparkListenerInterface
  44. def onNodeUnblacklisted(nodeUnblacklisted: SparkListenerNodeUnblacklisted): Unit
    Definition Classes
    SparkListener → SparkListenerInterface
  45. def onOtherEvent(event: SparkListenerEvent): Unit
    Definition Classes
    SparkListener → SparkListenerInterface
  46. def onSpeculativeTaskSubmitted(speculativeTask: SparkListenerSpeculativeTaskSubmitted): Unit
    Definition Classes
    SparkListener → SparkListenerInterface
  47. def onStageCompleted(stageCompleted: SparkListenerStageCompleted): Unit
    Definition Classes
    SparkPipelineListener → SparkListener → SparkListenerInterface
  48. def onStageExecutorMetrics(executorMetrics: SparkListenerStageExecutorMetrics): Unit
    Definition Classes
    SparkListener → SparkListenerInterface
  49. def onStageSubmitted(stageSubmitted: SparkListenerStageSubmitted): Unit
    Definition Classes
    SparkListener → SparkListenerInterface
  50. def onTaskEnd(taskEnd: SparkListenerTaskEnd): Unit
    Definition Classes
    SparkListener → SparkListenerInterface
  51. def onTaskGettingResult(taskGettingResult: SparkListenerTaskGettingResult): Unit
    Definition Classes
    SparkListener → SparkListenerInterface
  52. def onTaskStart(taskStart: SparkListenerTaskStart): Unit
    Definition Classes
    SparkListener → SparkListenerInterface
  53. def onUnpersistRDD(unpersistRDD: SparkListenerUnpersistRDD): Unit
    Definition Classes
    SparkListener → SparkListenerInterface
  54. def pipelineFinished(pipeline: Pipeline, pipelineContext: PipelineContext): Option[PipelineContext]
    Definition Classes
    KinesisPipelineListener → SparkPipelineListener → PipelineListener
  55. def pipelineStarted(pipeline: Pipeline, pipelineContext: PipelineContext): Option[PipelineContext]
    Definition Classes
    KinesisPipelineListener → SparkPipelineListener → PipelineListener
  56. def pipelineStepFinished(pipeline: Pipeline, step: PipelineStep, pipelineContext: PipelineContext): Option[PipelineContext]
    Definition Classes
    KinesisPipelineListener → SparkPipelineListener → PipelineListener
  57. def pipelineStepStarted(pipeline: Pipeline, step: PipelineStep, pipelineContext: PipelineContext): Option[PipelineContext]
    Definition Classes
    KinesisPipelineListener → SparkPipelineListener → PipelineListener
  58. def registerStepException(exception: PipelineStepException, pipelineContext: PipelineContext): Unit
    Definition Classes
    KinesisPipelineListener → PipelineListener
  59. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  60. def toString(): String
    Definition Classes
    AnyRef → Any
  61. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  62. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  63. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()

Inherited from EventBasedPipelineListener

Inherited from SparkPipelineListener

Inherited from PipelineListener

Inherited from SparkListener

Inherited from SparkListenerInterface

Inherited from AnyRef

Inherited from Any

Ungrouped