object GeneralSourceOptions extends OptionDescriptionBuilder
Defines the options that can be used on any source.
- Alphabetic
- By Inheritance
- GeneralSourceOptions
- OptionDescriptionBuilder
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
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
-
val
CSV_DELIMITER: String
The seperator to expect when reading CSV input.
The seperator to expect when reading CSV input. Default is ';'.
-
val
INCLUDE_SUBFOLDERS: String
Whether to include mails in subfolders when reading from inboxes.
Whether to include mails in subfolders when reading from inboxes. Only used with ConnectionProtocols.exchange. Default is
false. -
val
INDEX_BY: String
A column to use for indexing of the data.
A column to use for indexing of the data. This will make queries and joins on this column faster. The number of unique values in the column should not exceed 10000.
-
val
IN_MEMORY_CACHE_TIME: String
The number of minutes to cache sources, that are only run in-memory, for queries.
The number of minutes to cache sources, that are only run in-memory, for queries. Default is 0.
-
val
IN_MEMORY_ONLY: String
Whether to only run the source in-memory (as opposed to persisted).
Whether to only run the source in-memory (as opposed to persisted). Default is
false. -
def
Mandatory(name: String, validation: (String) ⇒ Option[String] = s => None): OptionDescription
- Attributes
- protected
- Definition Classes
- OptionDescriptionBuilder
-
def
Optional(name: String, default: Option[String] = None, validation: (String) ⇒ Option[String] = s => None): OptionDescription
- Attributes
- protected
- Definition Classes
- OptionDescriptionBuilder
-
val
PARTITION_BY: String
Partitions the source input using the given comparable column.
Partitions the source input using the given comparable column. This is used to avoid timeouts on large amounts of input tables in databases. The column should be indexed in the database. Default is not to partition input.
-
val
PARTITION_SIZE: String
The number of partitions to split the source input into.
The number of partitions to split the source input into. This is used to avoid timeouts on large amounts of input tables in databases. The column should be indexed in the database. Default is not to partition input.
-
val
REQUIRE_NON_EMPTY: String
Whether to require non-empty for the source to complete a run successfully.
Whether to require non-empty for the source to complete a run successfully. This is used when waiting for an external source to make output available, since failed runs can be retried automatically. Default is
false. -
val
STRING_ENCODING: String
The text encoding to expect when reading text input Default is UTF-8.
-
val
TRIM_STRINGS: String
Whether to trim string columns for leading and trailing whitespace
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
- def baseDescriptions: List[OptionDescription]
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native() @HotSpotIntrinsicCandidate()
-
def
descriptions(descriptions: OptionDescription*): OptionDescriptions
- Attributes
- protected
- Definition Classes
- OptionDescriptionBuilder
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
get: OptionDescriptions
- Definition Classes
- GeneralSourceOptions → OptionDescriptionBuilder
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
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()
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
Deprecated Value Members
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] ) @Deprecated
- Deprecated