Skip to content

Commit 48b0c0f

Browse files
authored
[FLINK-25756] Add Opensearch connector
1 parent ee6feb9 commit 48b0c0f

File tree

83 files changed

+10529
-0
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

83 files changed

+10529
-0
lines changed

.editorconfig

Lines changed: 276 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,276 @@
1+
root = true
2+
3+
[*]
4+
charset = utf-8
5+
end_of_line = lf
6+
insert_final_newline = true
7+
max_line_length = 100
8+
# ij_formatter_off_tag = @formatter:off
9+
# ij_formatter_on_tag = @formatter:on
10+
# ij_formatter_tags_enabled = false
11+
# ij_smart_tabs = false
12+
# ij_wrap_on_typing = false
13+
14+
[*.java]
15+
indent_size = 4
16+
indent_style = space
17+
tab_width = 4
18+
ij_continuation_indent_size = 8
19+
# ij_java_align_consecutive_assignments = false
20+
# ij_java_align_consecutive_variable_declarations = false
21+
# ij_java_align_group_field_declarations = false
22+
# ij_java_align_multiline_annotation_parameters = false
23+
# ij_java_align_multiline_array_initializer_expression = false
24+
# ij_java_align_multiline_assignment = false
25+
# ij_java_align_multiline_binary_operation = false
26+
# ij_java_align_multiline_chained_methods = false
27+
# ij_java_align_multiline_extends_list = false
28+
# ij_java_align_multiline_for = true
29+
# ij_java_align_multiline_method_parentheses = false
30+
# ij_java_align_multiline_parameters = true
31+
# ij_java_align_multiline_parameters_in_calls = false
32+
# ij_java_align_multiline_parenthesized_expression = false
33+
# ij_java_align_multiline_records = true
34+
# ij_java_align_multiline_resources = true
35+
# ij_java_align_multiline_ternary_operation = false
36+
# ij_java_align_multiline_text_blocks = false
37+
# ij_java_align_multiline_throws_list = false
38+
# ij_java_align_subsequent_simple_methods = false
39+
# ij_java_align_throws_keyword = false
40+
# ij_java_annotation_parameter_wrap = off
41+
# ij_java_array_initializer_new_line_after_left_brace = false
42+
# ij_java_array_initializer_right_brace_on_new_line = false
43+
# ij_java_array_initializer_wrap = off
44+
# ij_java_assert_statement_colon_on_next_line = false
45+
# ij_java_assert_statement_wrap = off
46+
# ij_java_assignment_wrap = off
47+
ij_java_binary_operation_sign_on_next_line = true
48+
ij_java_binary_operation_wrap = normal
49+
# ij_java_blank_lines_after_anonymous_class_header = 0
50+
# ij_java_blank_lines_after_class_header = 0
51+
# ij_java_blank_lines_after_imports = 1
52+
# ij_java_blank_lines_after_package = 1
53+
# ij_java_blank_lines_around_class = 1
54+
# ij_java_blank_lines_around_field = 0
55+
# ij_java_blank_lines_around_field_in_interface = 0
56+
# ij_java_blank_lines_around_initializer = 1
57+
# ij_java_blank_lines_around_method = 1
58+
# ij_java_blank_lines_around_method_in_interface = 1
59+
# ij_java_blank_lines_before_class_end = 0
60+
# ij_java_blank_lines_before_imports = 1
61+
# ij_java_blank_lines_before_method_body = 0
62+
# ij_java_blank_lines_before_package = 0
63+
# ij_java_block_brace_style = end_of_line
64+
# ij_java_block_comment_at_first_column = true
65+
ij_java_call_parameters_new_line_after_left_paren = true
66+
# ij_java_call_parameters_right_paren_on_new_line = false
67+
ij_java_call_parameters_wrap = on_every_item
68+
# ij_java_case_statement_on_separate_line = true
69+
# ij_java_catch_on_new_line = false
70+
# ij_java_class_annotation_wrap = split_into_lines
71+
# ij_java_class_brace_style = end_of_line
72+
ij_java_class_count_to_use_import_on_demand = 9999
73+
# ij_java_class_names_in_javadoc = 1
74+
# ij_java_do_not_indent_top_level_class_members = false
75+
# ij_java_do_not_wrap_after_single_annotation = false
76+
# ij_java_do_while_brace_force = never
77+
# ij_java_doc_add_blank_line_after_description = true
78+
ij_java_doc_add_blank_line_after_param_comments = true
79+
ij_java_doc_add_blank_line_after_return = true
80+
# ij_java_doc_add_p_tag_on_empty_lines = true
81+
ij_java_doc_align_exception_comments = false
82+
ij_java_doc_align_param_comments = false
83+
ij_java_doc_do_not_wrap_if_one_line = true
84+
ij_java_doc_enable_formatting = true
85+
# ij_java_doc_enable_leading_asterisks = true
86+
ij_java_doc_indent_on_continuation = true
87+
ij_java_doc_keep_empty_lines = true
88+
# ij_java_doc_keep_empty_parameter_tag = true
89+
# ij_java_doc_keep_empty_return_tag = true
90+
# ij_java_doc_keep_empty_throws_tag = true
91+
# ij_java_doc_keep_invalid_tags = true
92+
# ij_java_doc_param_description_on_new_line = false
93+
ij_java_doc_preserve_line_breaks = false
94+
# ij_java_doc_use_throws_not_exception_tag = true
95+
# ij_java_else_on_new_line = false
96+
# ij_java_entity_dd_suffix = EJB
97+
# ij_java_entity_eb_suffix = Bean
98+
# ij_java_entity_hi_suffix = Home
99+
# ij_java_entity_lhi_prefix = Local
100+
# ij_java_entity_lhi_suffix = Home
101+
# ij_java_entity_li_prefix = Local
102+
# ij_java_entity_pk_class = java.lang.String
103+
# ij_java_entity_vo_suffix = VO
104+
# ij_java_enum_constants_wrap = off
105+
# ij_java_extends_keyword_wrap = off
106+
# ij_java_extends_list_wrap = off
107+
# ij_java_field_annotation_wrap = split_into_lines
108+
# ij_java_finally_on_new_line = false
109+
# ij_java_for_brace_force = never
110+
# ij_java_for_statement_new_line_after_left_paren = false
111+
# ij_java_for_statement_right_paren_on_new_line = false
112+
# ij_java_for_statement_wrap = off
113+
# ij_java_generate_final_locals = false
114+
# ij_java_generate_final_parameters = false
115+
# ij_java_if_brace_force = never
116+
ij_java_imports_layout = org.apache.flink.**,|,org.apache.flink.shaded.**,|,*,|,javax.**,|,java.**,|,scala.**,|,$*
117+
# ij_java_indent_case_from_switch = true
118+
# ij_java_insert_inner_class_imports = false
119+
# ij_java_insert_override_annotation = true
120+
# ij_java_keep_blank_lines_before_right_brace = 2
121+
# ij_java_keep_blank_lines_between_package_declaration_and_header = 2
122+
# ij_java_keep_blank_lines_in_code = 2
123+
# ij_java_keep_blank_lines_in_declarations = 2
124+
# ij_java_keep_control_statement_in_one_line = true
125+
# ij_java_keep_first_column_comment = true
126+
# ij_java_keep_indents_on_empty_lines = false
127+
# ij_java_keep_line_breaks = true
128+
# ij_java_keep_multiple_expressions_in_one_line = false
129+
# ij_java_keep_simple_blocks_in_one_line = false
130+
# ij_java_keep_simple_classes_in_one_line = false
131+
# ij_java_keep_simple_lambdas_in_one_line = false
132+
# ij_java_keep_simple_methods_in_one_line = false
133+
# ij_java_label_indent_absolute = false
134+
# ij_java_label_indent_size = 0
135+
# ij_java_lambda_brace_style = end_of_line
136+
ij_java_layout_static_imports_separately = true
137+
# ij_java_line_comment_add_space = false
138+
# ij_java_line_comment_at_first_column = true
139+
# ij_java_message_dd_suffix = EJB
140+
# ij_java_message_eb_suffix = Bean
141+
# ij_java_method_annotation_wrap = split_into_lines
142+
# ij_java_method_brace_style = end_of_line
143+
ij_java_method_call_chain_wrap = on_every_item
144+
ij_java_method_parameters_new_line_after_left_paren = true
145+
# ij_java_method_parameters_right_paren_on_new_line = false
146+
ij_java_method_parameters_wrap = on_every_item
147+
# ij_java_modifier_list_wrap = false
148+
ij_java_names_count_to_use_import_on_demand = 9999
149+
# ij_java_new_line_after_lparen_in_record_header = false
150+
# ij_java_packages_to_use_import_on_demand = java.awt.*,javax.swing.*
151+
# ij_java_parameter_annotation_wrap = off
152+
# ij_java_parentheses_expression_new_line_after_left_paren = false
153+
# ij_java_parentheses_expression_right_paren_on_new_line = false
154+
# ij_java_place_assignment_sign_on_next_line = false
155+
# ij_java_prefer_longer_names = true
156+
# ij_java_prefer_parameters_wrap = false
157+
# ij_java_record_components_wrap = normal
158+
# ij_java_repeat_synchronized = true
159+
# ij_java_replace_instanceof_and_cast = false
160+
# ij_java_replace_null_check = true
161+
# ij_java_replace_sum_lambda_with_method_ref = true
162+
# ij_java_resource_list_new_line_after_left_paren = false
163+
# ij_java_resource_list_right_paren_on_new_line = false
164+
# ij_java_resource_list_wrap = off
165+
# ij_java_rparen_on_new_line_in_record_header = false
166+
# ij_java_session_dd_suffix = EJB
167+
# ij_java_session_eb_suffix = Bean
168+
# ij_java_session_hi_suffix = Home
169+
# ij_java_session_lhi_prefix = Local
170+
# ij_java_session_lhi_suffix = Home
171+
# ij_java_session_li_prefix = Local
172+
# ij_java_session_si_suffix = Service
173+
# ij_java_space_after_closing_angle_bracket_in_type_argument = false
174+
# ij_java_space_after_colon = true
175+
# ij_java_space_after_comma = true
176+
# ij_java_space_after_comma_in_type_arguments = true
177+
# ij_java_space_after_for_semicolon = true
178+
# ij_java_space_after_quest = true
179+
# ij_java_space_after_type_cast = true
180+
# ij_java_space_before_annotation_array_initializer_left_brace = false
181+
# ij_java_space_before_annotation_parameter_list = false
182+
# ij_java_space_before_array_initializer_left_brace = false
183+
# ij_java_space_before_catch_keyword = true
184+
# ij_java_space_before_catch_left_brace = true
185+
# ij_java_space_before_catch_parentheses = true
186+
# ij_java_space_before_class_left_brace = true
187+
# ij_java_space_before_colon = true
188+
# ij_java_space_before_colon_in_foreach = true
189+
# ij_java_space_before_comma = false
190+
# ij_java_space_before_do_left_brace = true
191+
# ij_java_space_before_else_keyword = true
192+
# ij_java_space_before_else_left_brace = true
193+
# ij_java_space_before_finally_keyword = true
194+
# ij_java_space_before_finally_left_brace = true
195+
# ij_java_space_before_for_left_brace = true
196+
# ij_java_space_before_for_parentheses = true
197+
# ij_java_space_before_for_semicolon = false
198+
# ij_java_space_before_if_left_brace = true
199+
# ij_java_space_before_if_parentheses = true
200+
# ij_java_space_before_method_call_parentheses = false
201+
# ij_java_space_before_method_left_brace = true
202+
# ij_java_space_before_method_parentheses = false
203+
# ij_java_space_before_opening_angle_bracket_in_type_parameter = false
204+
# ij_java_space_before_quest = true
205+
# ij_java_space_before_switch_left_brace = true
206+
# ij_java_space_before_switch_parentheses = true
207+
# ij_java_space_before_synchronized_left_brace = true
208+
# ij_java_space_before_synchronized_parentheses = true
209+
# ij_java_space_before_try_left_brace = true
210+
# ij_java_space_before_try_parentheses = true
211+
# ij_java_space_before_type_parameter_list = false
212+
# ij_java_space_before_while_keyword = true
213+
# ij_java_space_before_while_left_brace = true
214+
# ij_java_space_before_while_parentheses = true
215+
# ij_java_space_inside_one_line_enum_braces = false
216+
# ij_java_space_within_empty_array_initializer_braces = false
217+
# ij_java_space_within_empty_method_call_parentheses = false
218+
# ij_java_space_within_empty_method_parentheses = false
219+
# ij_java_spaces_around_additive_operators = true
220+
# ij_java_spaces_around_assignment_operators = true
221+
# ij_java_spaces_around_bitwise_operators = true
222+
# ij_java_spaces_around_equality_operators = true
223+
# ij_java_spaces_around_lambda_arrow = true
224+
# ij_java_spaces_around_logical_operators = true
225+
# ij_java_spaces_around_method_ref_dbl_colon = false
226+
# ij_java_spaces_around_multiplicative_operators = true
227+
# ij_java_spaces_around_relational_operators = true
228+
# ij_java_spaces_around_shift_operators = true
229+
# ij_java_spaces_around_type_bounds_in_type_parameters = true
230+
# ij_java_spaces_around_unary_operator = false
231+
# ij_java_spaces_within_angle_brackets = false
232+
# ij_java_spaces_within_annotation_parentheses = false
233+
# ij_java_spaces_within_array_initializer_braces = false
234+
# ij_java_spaces_within_braces = false
235+
# ij_java_spaces_within_brackets = false
236+
# ij_java_spaces_within_cast_parentheses = false
237+
# ij_java_spaces_within_catch_parentheses = false
238+
# ij_java_spaces_within_for_parentheses = false
239+
# ij_java_spaces_within_if_parentheses = false
240+
# ij_java_spaces_within_method_call_parentheses = false
241+
# ij_java_spaces_within_method_parentheses = false
242+
# ij_java_spaces_within_parentheses = false
243+
# ij_java_spaces_within_switch_parentheses = false
244+
# ij_java_spaces_within_synchronized_parentheses = false
245+
# ij_java_spaces_within_try_parentheses = false
246+
# ij_java_spaces_within_while_parentheses = false
247+
# ij_java_special_else_if_treatment = true
248+
# ij_java_subclass_name_suffix = Impl
249+
# ij_java_ternary_operation_signs_on_next_line = false
250+
# ij_java_ternary_operation_wrap = off
251+
# ij_java_test_name_suffix = Test
252+
# ij_java_throws_keyword_wrap = off
253+
# ij_java_throws_list_wrap = off
254+
# ij_java_use_external_annotations = false
255+
# ij_java_use_fq_class_names = false
256+
# ij_java_use_relative_indents = false
257+
# ij_java_use_single_class_imports = true
258+
ij_java_variable_annotation_wrap = normal
259+
# ij_java_visibility = public
260+
# ij_java_while_brace_force = never
261+
# ij_java_while_on_new_line = false
262+
# ij_java_wrap_comments = false
263+
ij_java_wrap_first_method_in_call_chain = true
264+
# ij_java_wrap_long_lines = false
265+
266+
[*.xml]
267+
indent_style = tab
268+
indent_size = 4
269+
270+
[*.scala]
271+
indent_style = space
272+
indent_size = 2
273+
274+
[*.py]
275+
indent_style = space
276+
indent_size = 4

.gitignore

Lines changed: 38 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,38 @@
1+
.eslintcache
2+
.cache
3+
scalastyle-output.xml
4+
.classpath
5+
.idea/*
6+
!.idea/vcs.xml
7+
.metadata
8+
.settings
9+
.project
10+
.version.properties
11+
filter.properties
12+
logs.zip
13+
.mvn/wrapper/*.jar
14+
target
15+
tmp
16+
*.class
17+
*.iml
18+
*.swp
19+
*.jar
20+
*.zip
21+
*.log
22+
*.pyc
23+
.DS_Store
24+
build-target
25+
atlassian-ide-plugin.xml
26+
out/
27+
/docs/api
28+
/docs/.bundle
29+
/docs/.rubydeps
30+
/docs/ruby2/.bundle
31+
/docs/ruby2/.rubydeps
32+
/docs/.jekyll-metadata
33+
*.ipr
34+
*.iws
35+
tools/flink
36+
tools/flink-*
37+
tools/releasing/release
38+
tools/japicmp-output

0 commit comments

Comments
 (0)