7#include <aws/glue/Glue_EXPORTS.h>
8#include <aws/core/utils/memory/stl/AWSString.h>
9#include <aws/glue/model/KinesisStreamingSourceOptions.h>
10#include <aws/glue/model/StreamingDataPreviewOptions.h>
49 template<
typename NameT = Aws::String>
50 void SetName(NameT&& value) { m_nameHasBeenSet =
true; m_name = std::forward<NameT>(value); }
51 template<
typename NameT = Aws::String>
61 inline void SetWindowSize(
int value) { m_windowSizeHasBeenSet =
true; m_windowSize = value; }
71 inline void SetDetectSchema(
bool value) { m_detectSchemaHasBeenSet =
true; m_detectSchema = value; }
81 template<
typename TableT = Aws::String>
82 void SetTable(TableT&& value) { m_tableHasBeenSet =
true; m_table = std::forward<TableT>(value); }
83 template<
typename TableT = Aws::String>
93 template<
typename DatabaseT = Aws::String>
94 void SetDatabase(DatabaseT&& value) { m_databaseHasBeenSet =
true; m_database = std::forward<DatabaseT>(value); }
95 template<
typename DatabaseT = Aws::String>
105 template<
typename StreamingOptionsT = KinesisStreamingSourceOptions>
106 void SetStreamingOptions(StreamingOptionsT&& value) { m_streamingOptionsHasBeenSet =
true; m_streamingOptions = std::forward<StreamingOptionsT>(value); }
107 template<
typename StreamingOptionsT = KinesisStreamingSourceOptions>
117 template<
typename DataPreviewOptionsT = StreamingDataPreviewOptions>
118 void SetDataPreviewOptions(DataPreviewOptionsT&& value) { m_dataPreviewOptionsHasBeenSet =
true; m_dataPreviewOptions = std::forward<DataPreviewOptionsT>(value); }
119 template<
typename DataPreviewOptionsT = StreamingDataPreviewOptions>
125 bool m_nameHasBeenSet =
false;
128 bool m_windowSizeHasBeenSet =
false;
130 bool m_detectSchema{
false};
131 bool m_detectSchemaHasBeenSet =
false;
134 bool m_tableHasBeenSet =
false;
137 bool m_databaseHasBeenSet =
false;
139 KinesisStreamingSourceOptions m_streamingOptions;
140 bool m_streamingOptionsHasBeenSet =
false;
142 StreamingDataPreviewOptions m_dataPreviewOptions;
143 bool m_dataPreviewOptionsHasBeenSet =
false;
CatalogKinesisSource & WithDataPreviewOptions(DataPreviewOptionsT &&value)
AWS_GLUE_API Aws::Utils::Json::JsonValue Jsonize() const
bool GetDetectSchema() const
bool StreamingOptionsHasBeenSet() const
void SetDatabase(DatabaseT &&value)
void SetDataPreviewOptions(DataPreviewOptionsT &&value)
void SetStreamingOptions(StreamingOptionsT &&value)
void SetName(NameT &&value)
CatalogKinesisSource & WithTable(TableT &&value)
bool NameHasBeenSet() const
const StreamingDataPreviewOptions & GetDataPreviewOptions() const
bool DatabaseHasBeenSet() const
CatalogKinesisSource & WithName(NameT &&value)
const Aws::String & GetDatabase() const
CatalogKinesisSource & WithDetectSchema(bool value)
CatalogKinesisSource & WithWindowSize(int value)
CatalogKinesisSource & WithStreamingOptions(StreamingOptionsT &&value)
AWS_GLUE_API CatalogKinesisSource(Aws::Utils::Json::JsonView jsonValue)
void SetWindowSize(int value)
const KinesisStreamingSourceOptions & GetStreamingOptions() const
bool DataPreviewOptionsHasBeenSet() const
bool TableHasBeenSet() const
CatalogKinesisSource & WithDatabase(DatabaseT &&value)
const Aws::String & GetName() const
int GetWindowSize() const
AWS_GLUE_API CatalogKinesisSource()=default
AWS_GLUE_API CatalogKinesisSource & operator=(Aws::Utils::Json::JsonView jsonValue)
void SetDetectSchema(bool value)
bool WindowSizeHasBeenSet() const
const Aws::String & GetTable() const
void SetTable(TableT &&value)
bool DetectSchemaHasBeenSet() const
std::basic_string< char, std::char_traits< char >, Aws::Allocator< char > > String
Aws::Utils::Json::JsonValue JsonValue