Packages

object StateStoreErrors

Object for grouping error messages from (most) exceptions thrown from State Store

ERROR_CLASS has a prefix of "STATE_STORE_" to indicate where the error is from

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. StateStoreErrors
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

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 cannotCreateColumnFamilyWithReservedChars(colFamilyName: String): StateStoreCannotCreateColumnFamilyWithReservedChars
  6. def cannotLoadStore(e: Throwable): Throwable
  7. def cannotPerformOperationWithInvalidHandleState(operationType: String, handleState: String): StatefulProcessorCannotPerformOperationWithInvalidHandleState
  8. def cannotPerformOperationWithInvalidTimeMode(operationType: String, timeMode: String): StatefulProcessorCannotPerformOperationWithInvalidTimeMode
  9. def cannotProvideTTLConfigForTimeMode(stateName: String, timeMode: String): StatefulProcessorCannotAssignTTLInTimeMode
  10. def cannotUseColumnFamilyWithInvalidName(operationName: String, colFamilyName: String): StateStoreCannotUseColumnFamilyWithInvalidName
  11. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  12. def duplicateStateVariableDefined(stateName: String): StateStoreDuplicateStateVariableDefined
  13. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  14. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  15. def failedToGetChangelogWriter(version: Long, e: Throwable): StateStoreFailedToGetChangelogWriter
  16. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  17. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  18. def implicitKeyNotFound(stateName: String): SparkException
  19. def incorrectNumOrderingColsForPrefixScan(numPrefixCols: String): StateStoreIncorrectNumOrderingColsForPrefixScan
  20. def incorrectNumOrderingColsForRangeScan(numOrderingCols: String): StateStoreIncorrectNumOrderingColsForRangeScan
  21. def invalidConfigChangedAfterRestart(configName: String, oldConfig: String, newConfig: String): StateStoreInvalidConfigAfterRestart
  22. def invalidStamp(providedStamp: Long, currentStamp: Long): StateStoreInvalidStamp
  23. def invalidStateMachineTransition(oldState: String, newState: String, transition: String, storeId: StateStoreId): StateStoreInvalidStateMachineTransition
  24. def invalidVariableTypeChange(stateName: String, oldType: String, newType: String): StateStoreInvalidVariableTypeChange
  25. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  26. def keyRowFormatValidationFailure(errorMsg: String, stateStoreID: String): StateStoreKeyRowFormatValidationFailure
  27. def missingTimeValues(timeMode: String): SparkException
  28. def multipleColumnFamiliesNotSupported(stateStoreProvider: String): StateStoreMultipleColumnFamiliesNotSupportedException
  29. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  30. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  31. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  32. def nullTypeOrderingColsNotSupported(fieldName: String, index: String): StateStoreNullTypeOrderingColsNotSupported
  33. def removingColumnFamiliesNotSupported(stateStoreProvider: String): StateStoreRemovingColumnFamiliesNotSupportedException
  34. def requireNonEmptyListStateValue[S](value: Array[S], stateName: String): Unit
  35. def requireNonNullStateValue(value: Any, stateName: String): Unit
  36. def stateStoreCheckpointIdsNotSupported(msg: String): StateStoreCheckpointIdsNotSupported
  37. def stateStoreColumnFamilyMismatch(columnFamilyName: String, oldColumnFamilySchema: String, newColumnFamilySchema: String): StateStoreColumnFamilyMismatch
  38. def stateStoreCommitValidationFailed(batchId: Long, expectedCommits: Int, actualCommits: Int, missingCommits: String): StateStoreCommitValidationFailed
  39. def stateStoreInvalidValueSchemaEvolution(oldValueSchema: String, newValueSchema: String): StateStoreInvalidValueSchemaEvolution
  40. def stateStoreKeySchemaNotCompatible(storedKeySchema: String, newKeySchema: String): StateStoreKeySchemaNotCompatible
  41. def stateStoreOperationOutOfOrder(errorMsg: String): StateStoreOperationOutOfOrder
  42. def stateStoreProviderDoesNotSupportFineGrainedReplay(inputClass: String): StateStoreProviderDoesNotSupportFineGrainedReplay
  43. def stateStoreSnapshotFileNotFound(fileToRead: String, clazz: String): StateStoreSnapshotFileNotFound
  44. def stateStoreSnapshotPartitionNotFound(snapshotPartitionId: Long, operatorId: Int, checkpointLocation: String): StateStoreSnapshotPartitionNotFound
  45. def stateStoreValueSchemaEvolutionThresholdExceeded(numSchemaEvolutions: Int, maxSchemaEvolutions: Int, colFamilyName: String): StateStoreValueSchemaEvolutionThresholdExceeded
  46. def stateStoreValueSchemaNotCompatible(storedValueSchema: String, newValueSchema: String): StateStoreValueSchemaNotCompatible
  47. def streamingStateCheckpointLocationNotEmpty(checkpointLocation: String): StateStoreCheckpointLocationNotEmpty
  48. def streamingStateSchemaFilesThresholdExceeded(numSchemaFiles: Int, schemaFilesThreshold: Int, addedColFamilies: List[String], removedColFamilies: List[String]): StateStoreStateSchemaFilesThresholdExceeded
  49. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  50. def toString(): String
    Definition Classes
    AnyRef → Any
  51. def ttlMustBePositive(operationType: String, stateName: String): StatefulProcessorTTLMustBePositive
  52. def twsSchemaMustBeNullable(columnFamilyName: String, schema: String): TWSSchemaMustBeNullable
  53. def unexpectedEmptyFileInRocksDBZip(fileName: String, zipFileName: String): StateStoreUnexpectedEmptyFileInRocksDBZip
  54. def unsupportedOperationException(operationName: String, entity: String): StateStoreUnsupportedOperationException
  55. def unsupportedOperationOnMissingColumnFamily(operationName: String, colFamilyName: String): StateStoreUnsupportedOperationOnMissingColumnFamily
  56. def valueRowFormatValidationFailure(errorMsg: String, stateStoreID: String): StateStoreValueRowFormatValidationFailure
  57. def variableSizeOrderingColsNotSupported(fieldName: String, index: String): StateStoreVariableSizeOrderingColsNotSupported
  58. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  59. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  60. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from AnyRef

Inherited from Any

Ungrouped