AWS SDK for C++

AWS SDK for C++ Version 1.11.606

Loading...
Searching...
No Matches
CatalogKinesisSource.h
1
6#pragma once
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>
11#include <utility>
12
13namespace Aws
14{
15namespace Utils
16{
17namespace Json
18{
19 class JsonValue;
20 class JsonView;
21} // namespace Json
22} // namespace Utils
23namespace Glue
24{
25namespace Model
26{
27
35 {
36 public:
37 AWS_GLUE_API CatalogKinesisSource() = default;
41
42
44
47 inline const Aws::String& GetName() const { return m_name; }
48 inline bool NameHasBeenSet() const { return m_nameHasBeenSet; }
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>
52 CatalogKinesisSource& WithName(NameT&& value) { SetName(std::forward<NameT>(value)); return *this;}
54
56
59 inline int GetWindowSize() const { return m_windowSize; }
60 inline bool WindowSizeHasBeenSet() const { return m_windowSizeHasBeenSet; }
61 inline void SetWindowSize(int value) { m_windowSizeHasBeenSet = true; m_windowSize = value; }
62 inline CatalogKinesisSource& WithWindowSize(int value) { SetWindowSize(value); return *this;}
64
66
69 inline bool GetDetectSchema() const { return m_detectSchema; }
70 inline bool DetectSchemaHasBeenSet() const { return m_detectSchemaHasBeenSet; }
71 inline void SetDetectSchema(bool value) { m_detectSchemaHasBeenSet = true; m_detectSchema = value; }
72 inline CatalogKinesisSource& WithDetectSchema(bool value) { SetDetectSchema(value); return *this;}
74
76
79 inline const Aws::String& GetTable() const { return m_table; }
80 inline bool TableHasBeenSet() const { return m_tableHasBeenSet; }
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>
84 CatalogKinesisSource& WithTable(TableT&& value) { SetTable(std::forward<TableT>(value)); return *this;}
86
88
91 inline const Aws::String& GetDatabase() const { return m_database; }
92 inline bool DatabaseHasBeenSet() const { return m_databaseHasBeenSet; }
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>
96 CatalogKinesisSource& WithDatabase(DatabaseT&& value) { SetDatabase(std::forward<DatabaseT>(value)); return *this;}
98
100
103 inline const KinesisStreamingSourceOptions& GetStreamingOptions() const { return m_streamingOptions; }
104 inline bool StreamingOptionsHasBeenSet() const { return m_streamingOptionsHasBeenSet; }
105 template<typename StreamingOptionsT = KinesisStreamingSourceOptions>
106 void SetStreamingOptions(StreamingOptionsT&& value) { m_streamingOptionsHasBeenSet = true; m_streamingOptions = std::forward<StreamingOptionsT>(value); }
107 template<typename StreamingOptionsT = KinesisStreamingSourceOptions>
108 CatalogKinesisSource& WithStreamingOptions(StreamingOptionsT&& value) { SetStreamingOptions(std::forward<StreamingOptionsT>(value)); return *this;}
110
112
115 inline const StreamingDataPreviewOptions& GetDataPreviewOptions() const { return m_dataPreviewOptions; }
116 inline bool DataPreviewOptionsHasBeenSet() const { return m_dataPreviewOptionsHasBeenSet; }
117 template<typename DataPreviewOptionsT = StreamingDataPreviewOptions>
118 void SetDataPreviewOptions(DataPreviewOptionsT&& value) { m_dataPreviewOptionsHasBeenSet = true; m_dataPreviewOptions = std::forward<DataPreviewOptionsT>(value); }
119 template<typename DataPreviewOptionsT = StreamingDataPreviewOptions>
120 CatalogKinesisSource& WithDataPreviewOptions(DataPreviewOptionsT&& value) { SetDataPreviewOptions(std::forward<DataPreviewOptionsT>(value)); return *this;}
122 private:
123
124 Aws::String m_name;
125 bool m_nameHasBeenSet = false;
126
127 int m_windowSize{0};
128 bool m_windowSizeHasBeenSet = false;
129
130 bool m_detectSchema{false};
131 bool m_detectSchemaHasBeenSet = false;
132
133 Aws::String m_table;
134 bool m_tableHasBeenSet = false;
135
136 Aws::String m_database;
137 bool m_databaseHasBeenSet = false;
138
139 KinesisStreamingSourceOptions m_streamingOptions;
140 bool m_streamingOptionsHasBeenSet = false;
141
142 StreamingDataPreviewOptions m_dataPreviewOptions;
143 bool m_dataPreviewOptionsHasBeenSet = false;
144 };
145
146} // namespace Model
147} // namespace Glue
148} // namespace Aws
CatalogKinesisSource & WithDataPreviewOptions(DataPreviewOptionsT &&value)
AWS_GLUE_API Aws::Utils::Json::JsonValue Jsonize() const
void SetDataPreviewOptions(DataPreviewOptionsT &&value)
void SetStreamingOptions(StreamingOptionsT &&value)
CatalogKinesisSource & WithTable(TableT &&value)
const StreamingDataPreviewOptions & GetDataPreviewOptions() const
CatalogKinesisSource & WithName(NameT &&value)
CatalogKinesisSource & WithDetectSchema(bool value)
CatalogKinesisSource & WithWindowSize(int value)
CatalogKinesisSource & WithStreamingOptions(StreamingOptionsT &&value)
AWS_GLUE_API CatalogKinesisSource(Aws::Utils::Json::JsonView jsonValue)
const KinesisStreamingSourceOptions & GetStreamingOptions() const
CatalogKinesisSource & WithDatabase(DatabaseT &&value)
AWS_GLUE_API CatalogKinesisSource()=default
AWS_GLUE_API CatalogKinesisSource & operator=(Aws::Utils::Json::JsonView jsonValue)
std::basic_string< char, std::char_traits< char >, Aws::Allocator< char > > String
Aws::Utils::Json::JsonValue JsonValue