Packages

object StateStoreErrors

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

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