Copyright	(c) 2013-2023 Brendan Hay
License	Mozilla Public License, v. 2.0.
Maintainer	Brendan Hay
Stability	auto-generated
Portability	non-portable (GHC extensions)
Safe Haskell	Safe-Inferred
Language	Haskell2010

Amazonka.Glue.Types.CatalogKafkaSource

Description

Synopsis

Documentation

data CatalogKafkaSource Source #

Specifies an Apache Kafka data store in the Data Catalog.

See: newCatalogKafkaSource smart constructor.

Constructors

CatalogKafkaSource'

Fields

dataPreviewOptions :: Maybe StreamingDataPreviewOptions
Specifies options related to data preview for viewing a sample of your data.
detectSchema :: Maybe Bool
Whether to automatically determine the schema from the incoming data.
streamingOptions :: Maybe KafkaStreamingSourceOptions
Specifies the streaming options.
windowSize :: Maybe Natural
The amount of time to spend processing each micro batch.
name :: Text
The name of the data store.
table :: Text
The name of the table in the database to read from.
database :: Text
The name of the database to read from.

Instances

Instances details

FromJSON CatalogKafkaSource Source #
Instance details Defined in Amazonka.Glue.Types.CatalogKafkaSource Methods parseJSON :: Value -> Parser CatalogKafkaSource # parseJSONList :: Value -> Parser [CatalogKafkaSource] #
ToJSON CatalogKafkaSource Source #
Instance details Defined in Amazonka.Glue.Types.CatalogKafkaSource Methods toJSON :: CatalogKafkaSource -> Value # toEncoding :: CatalogKafkaSource -> Encoding # toJSONList :: [CatalogKafkaSource] -> Value # toEncodingList :: [CatalogKafkaSource] -> Encoding #
Generic CatalogKafkaSource Source #
Instance details Defined in Amazonka.Glue.Types.CatalogKafkaSource Associated Types type Rep CatalogKafkaSource :: Type -> Type # Methods from :: CatalogKafkaSource -> Rep CatalogKafkaSource x # to :: Rep CatalogKafkaSource x -> CatalogKafkaSource #
Read CatalogKafkaSource Source #
Instance details Defined in Amazonka.Glue.Types.CatalogKafkaSource Methods readsPrec :: Int -> ReadS CatalogKafkaSource # readList :: ReadS [CatalogKafkaSource] # readPrec :: ReadPrec CatalogKafkaSource # readListPrec :: ReadPrec [CatalogKafkaSource] #
Show CatalogKafkaSource Source #
Instance details Defined in Amazonka.Glue.Types.CatalogKafkaSource Methods showsPrec :: Int -> CatalogKafkaSource -> ShowS # show :: CatalogKafkaSource -> String # showList :: [CatalogKafkaSource] -> ShowS #
NFData CatalogKafkaSource Source #
Instance details Defined in Amazonka.Glue.Types.CatalogKafkaSource Methods rnf :: CatalogKafkaSource -> () #
Eq CatalogKafkaSource Source #
Instance details Defined in Amazonka.Glue.Types.CatalogKafkaSource Methods (==) :: CatalogKafkaSource -> CatalogKafkaSource -> Bool # (/=) :: CatalogKafkaSource -> CatalogKafkaSource -> Bool #
Hashable CatalogKafkaSource Source #
Instance details Defined in Amazonka.Glue.Types.CatalogKafkaSource Methods hashWithSalt :: Int -> CatalogKafkaSource -> Int # hash :: CatalogKafkaSource -> Int #
type Rep CatalogKafkaSource Source #
Instance details Defined in Amazonka.Glue.Types.CatalogKafkaSource type Rep CatalogKafkaSource = D1 ('MetaData "CatalogKafkaSource" "Amazonka.Glue.Types.CatalogKafkaSource" "amazonka-glue-2.0-7miPWwBHdfn8N8SvbpLgE0" 'False) (C1 ('MetaCons "CatalogKafkaSource'" 'PrefixI 'True) ((S1 ('MetaSel ('Just "dataPreviewOptions") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe StreamingDataPreviewOptions)) :: (S1 ('MetaSel ('Just "detectSchema") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe Bool)) :: S1 ('MetaSel ('Just "streamingOptions") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe KafkaStreamingSourceOptions)))) :: ((S1 ('MetaSel ('Just "windowSize") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe Natural)) :: S1 ('MetaSel ('Just "name") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 Text)) :: (S1 ('MetaSel ('Just "table") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 Text) :: S1 ('MetaSel ('Just "database") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 Text)))))

newCatalogKafkaSource Source #

Arguments

:: Text	`$sel:name:CatalogKafkaSource'`
-> Text	`$sel:table:CatalogKafkaSource'`
-> Text	`$sel:database:CatalogKafkaSource'`
-> CatalogKafkaSource

Create a value of CatalogKafkaSource with all optional fields omitted.

Use generic-lens or optics to modify other optional fields.

The following record fields are available, with the corresponding lenses provided for backwards compatibility:

$sel:dataPreviewOptions:CatalogKafkaSource', catalogKafkaSource_dataPreviewOptions - Specifies options related to data preview for viewing a sample of your data.

$sel:detectSchema:CatalogKafkaSource', catalogKafkaSource_detectSchema - Whether to automatically determine the schema from the incoming data.

$sel:streamingOptions:CatalogKafkaSource', catalogKafkaSource_streamingOptions - Specifies the streaming options.

$sel:windowSize:CatalogKafkaSource', catalogKafkaSource_windowSize - The amount of time to spend processing each micro batch.

$sel:name:CatalogKafkaSource', catalogKafkaSource_name - The name of the data store.

$sel:table:CatalogKafkaSource', catalogKafkaSource_table - The name of the table in the database to read from.

$sel:database:CatalogKafkaSource', catalogKafkaSource_database - The name of the database to read from.

catalogKafkaSource_dataPreviewOptions :: Lens' CatalogKafkaSource (Maybe StreamingDataPreviewOptions) Source #

Specifies options related to data preview for viewing a sample of your data.

catalogKafkaSource_detectSchema :: Lens' CatalogKafkaSource (Maybe Bool) Source #

Whether to automatically determine the schema from the incoming data.

catalogKafkaSource_streamingOptions :: Lens' CatalogKafkaSource (Maybe KafkaStreamingSourceOptions) Source #

Specifies the streaming options.

catalogKafkaSource_windowSize :: Lens' CatalogKafkaSource (Maybe Natural) Source #

The amount of time to spend processing each micro batch.

catalogKafkaSource_name :: Lens' CatalogKafkaSource Text Source #

The name of the data store.

catalogKafkaSource_table :: Lens' CatalogKafkaSource Text Source #

The name of the table in the database to read from.

catalogKafkaSource_database :: Lens' CatalogKafkaSource Text Source #

The name of the database to read from.