object Files
- Note
General note on working with files in Checkita Framework:
- Path may contain file system connector prefix such as
file://
to read from local file system ors3a://
to read from S3 storage. - It is up to user to setup all required spark configuration parameters to read from and write into specified file system.
- If file system connector prefix is not defined then files are always read from and written into Spark's default file system.
- Pay attention when running framework in local mode: in this case spark will read files from local file system only.
- Path may contain file system connector prefix such as
- Alphabetic
- By Inheritance
- Files
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
-
trait
AvroFileConfig extends FileConfig
Base trait for Avro files.
Base trait for Avro files. Configuration for avro files may contain reference to avro schema ID.
-
trait
DelimitedFileConfig extends FileConfig
Base trait for delimited text files such as CSV or TSV.
Base trait for delimited text files such as CSV or TSV. For such file configuration must contain following parameters:
- delimiter symbol
- quote symbol
- escape symbol
- flag indicating that schema must be read from header
- explicit schema ID for cases when header is absent or should be ignored
-
trait
FileConfig extends AnyRef
Base trait for all types of configurations that refer to a file.
Base trait for all types of configurations that refer to a file. All such configurations must contain a path to a file. In addition, optional schemaId can be provided to point to a schema used for data reading.
-
trait
FixedFileConfig extends FileConfig
Base trait for fixed-width text files.
Base trait for fixed-width text files. For such files configuration must contain reference explicit fixed (full or short) schema ID
-
trait
OrcFileConfig extends FileConfig
Base trait for ORC files
-
trait
ParquetFileConfig extends FileConfig
Base trait for Parquet files
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
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
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()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
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()