diff --git a/flink-1.3.2/.idea/workspace.xml b/flink-1.3.2/.idea/workspace.xml
index ec600359779f26b9bf04a3117b7747c078c4ca21..475c39cf21541971ec9ac535d6662dde8ee64ba7 100644
--- a/flink-1.3.2/.idea/workspace.xml
+++ b/flink-1.3.2/.idea/workspace.xml
@@ -2,6 +2,90 @@
<project version="4">
<component name="ChangeListManager">
<list default="true" id="0afa927f-5482-46c2-9b5c-87084438c728" name="Default" comment="" />
+ <ignored path="$PROJECT_DIR$/flink-shaded-curator/flink-shaded-curator-test/target/" />
+ <ignored path="$PROJECT_DIR$/flink-shaded-hadoop/target/" />
+ <ignored path="$PROJECT_DIR$/flink-libraries/flink-ml/target/" />
+ <ignored path="$PROJECT_DIR$/flink-contrib/flink-storm/target/" />
+ <ignored path="$PROJECT_DIR$/flink-scala-shell/target/" />
+ <ignored path="$PROJECT_DIR$/flink-streaming-scala/target/" />
+ <ignored path="$PROJECT_DIR$/flink-dist/target/" />
+ <ignored path="$PROJECT_DIR$/flink-annotations/target/" />
+ <ignored path="$PROJECT_DIR$/flink-connectors/flink-hadoop-compatibility/target/" />
+ <ignored path="$PROJECT_DIR$/flink-test-utils-parent/target/" />
+ <ignored path="$PROJECT_DIR$/flink-connectors/flink-connector-kafka-0.8/target/" />
+ <ignored path="$PROJECT_DIR$/flink-optimizer/target/" />
+ <ignored path="$PROJECT_DIR$/flink-quickstart/flink-quickstart-scala/src/main/resources/archetype-resources/target/" />
+ <ignored path="$PROJECT_DIR$/target/" />
+ <ignored path="$PROJECT_DIR$/flink-connectors/flink-jdbc/target/" />
+ <ignored path="$PROJECT_DIR$/flink-examples/flink-examples-streaming/target/" />
+ <ignored path="$PROJECT_DIR$/flink-connectors/flink-connector-elasticsearch-base/target/" />
+ <ignored path="$PROJECT_DIR$/flink-connectors/target/" />
+ <ignored path="$PROJECT_DIR$/flink-examples/flink-examples-batch/target/" />
+ <ignored path="$PROJECT_DIR$/flink-libraries/flink-cep-scala/target/" />
+ <ignored path="$PROJECT_DIR$/flink-shaded-hadoop/flink-shaded-include-yarn-tests/target/" />
+ <ignored path="$PROJECT_DIR$/flink-streaming-java/target/" />
+ <ignored path="$PROJECT_DIR$/flink-connectors/flink-connector-kafka-base/target/" />
+ <ignored path="$PROJECT_DIR$/flink-contrib/flink-statebackend-rocksdb/target/" />
+ <ignored path="$PROJECT_DIR$/flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/target/" />
+ <ignored path="$PROJECT_DIR$/flink-clients/target/" />
+ <ignored path="$PROJECT_DIR$/flink-connectors/flink-connector-rabbitmq/target/" />
+ <ignored path="$PROJECT_DIR$/flink-examples/flink-examples-table/target/" />
+ <ignored path="$PROJECT_DIR$/flink-metrics/flink-metrics-dropwizard/target/" />
+ <ignored path="$PROJECT_DIR$/flink-connectors/flink-connector-nifi/target/" />
+ <ignored path="$PROJECT_DIR$/flink-test-utils-parent/flink-test-utils/target/" />
+ <ignored path="$PROJECT_DIR$/flink-examples/target/" />
+ <ignored path="$PROJECT_DIR$/flink-libraries/target/" />
+ <ignored path="$PROJECT_DIR$/flink-connectors/flink-avro/target/" />
+ <ignored path="$PROJECT_DIR$/flink-contrib/flink-storm-examples/target/" />
+ <ignored path="$PROJECT_DIR$/flink-yarn-tests/target/" />
+ <ignored path="$PROJECT_DIR$/flink-libraries/flink-gelly/target/" />
+ <ignored path="$PROJECT_DIR$/flink-metrics/flink-metrics-graphite/target/" />
+ <ignored path="$PROJECT_DIR$/flink-libraries/flink-gelly-scala/target/" />
+ <ignored path="$PROJECT_DIR$/flink-shaded-hadoop/flink-shaded-hadoop2-uber/target/" />
+ <ignored path="$PROJECT_DIR$/flink-test-utils-parent/flink-test-utils-junit/target/" />
+ <ignored path="$PROJECT_DIR$/flink-contrib/flink-tweet-inputformat/target/" />
+ <ignored path="$PROJECT_DIR$/flink-tests/target/" />
+ <ignored path="$PROJECT_DIR$/flink-shaded-curator/target/" />
+ <ignored path="$PROJECT_DIR$/flink-contrib/flink-connector-wikiedits/target/" />
+ <ignored path="$PROJECT_DIR$/flink-java/target/" />
+ <ignored path="$PROJECT_DIR$/flink-core/target/" />
+ <ignored path="$PROJECT_DIR$/flink-connectors/flink-connector-elasticsearch2/target/" />
+ <ignored path="$PROJECT_DIR$/tools/force-shading/target/" />
+ <ignored path="$PROJECT_DIR$/flink-connectors/flink-hbase/target/" />
+ <ignored path="$PROJECT_DIR$/flink-runtime-web/target/" />
+ <ignored path="$PROJECT_DIR$/flink-metrics/flink-metrics-ganglia/target/" />
+ <ignored path="$PROJECT_DIR$/flink-connectors/flink-connector-kera/target/" />
+ <ignored path="$PROJECT_DIR$/flink-connectors/flink-connector-elasticsearch5/target/" />
+ <ignored path="$PROJECT_DIR$/flink-scala/target/" />
+ <ignored path="$PROJECT_DIR$/flink-fs-tests/target/" />
+ <ignored path="$PROJECT_DIR$/flink-metrics/flink-metrics-core/target/" />
+ <ignored path="$PROJECT_DIR$/flink-metrics/flink-metrics-statsd/target/" />
+ <ignored path="$PROJECT_DIR$/flink-libraries/flink-gelly-examples/target/" />
+ <ignored path="$PROJECT_DIR$/flink-connectors/flink-connector-kafka-0.9/target/" />
+ <ignored path="$PROJECT_DIR$/flink-connectors/flink-connector-elasticsearch/target/" />
+ <ignored path="$PROJECT_DIR$/flink-yarn/target/" />
+ <ignored path="$PROJECT_DIR$/flink-connectors/flink-hcatalog/target/" />
+ <ignored path="$PROJECT_DIR$/flink-shaded-hadoop/flink-shaded-hadoop2/target/" />
+ <ignored path="$PROJECT_DIR$/flink-metrics/flink-metrics-datadog/target/" />
+ <ignored path="$PROJECT_DIR$/flink-connectors/flink-connector-twitter/target/" />
+ <ignored path="$PROJECT_DIR$/flink-mesos/target/" />
+ <ignored path="$PROJECT_DIR$/flink-connectors/flink-connector-cassandra/target/" />
+ <ignored path="$PROJECT_DIR$/flink-libraries/flink-python/target/" />
+ <ignored path="$PROJECT_DIR$/flink-libraries/flink-cep/target/" />
+ <ignored path="$PROJECT_DIR$/flink-shaded-curator/flink-shaded-curator-recipes/target/" />
+ <ignored path="$PROJECT_DIR$/flink-quickstart/flink-quickstart-java/target/" />
+ <ignored path="$PROJECT_DIR$/flink-quickstart/target/" />
+ <ignored path="$PROJECT_DIR$/flink-connectors/flink-connector-kinesis/target/" />
+ <ignored path="$PROJECT_DIR$/flink-java8/target/" />
+ <ignored path="$PROJECT_DIR$/flink-contrib/target/" />
+ <ignored path="$PROJECT_DIR$/flink-connectors/flink-connector-kafka-0.10/target/" />
+ <ignored path="$PROJECT_DIR$/flink-connectors/flink-connector-filesystem/target/" />
+ <ignored path="$PROJECT_DIR$/flink-contrib/flink-streaming-contrib/target/" />
+ <ignored path="$PROJECT_DIR$/flink-libraries/flink-table/target/" />
+ <ignored path="$PROJECT_DIR$/flink-metrics/target/" />
+ <ignored path="$PROJECT_DIR$/flink-quickstart/flink-quickstart-scala/target/" />
+ <ignored path="$PROJECT_DIR$/flink-runtime/target/" />
+ <ignored path="$PROJECT_DIR$/flink-metrics/flink-metrics-jmx/target/" />
<option name="EXCLUDED_CONVERTED_TO_IGNORED" value="true" />
<option name="TRACKING_ENABLED" value="true" />
<option name="SHOW_DIALOG" value="false" />
@@ -9,6 +93,124 @@
<option name="HIGHLIGHT_NON_ACTIVE_CHANGELIST" value="false" />
<option name="LAST_RESOLUTION" value="IGNORE" />
</component>
+ <component name="FileEditorManager">
+ <leaf SIDE_TABS_SIZE_LIMIT_KEY="300">
+ <file leaf-file-name="FlinkKeraConsumerBase.java" pinned="false" current-in-tab="true">
+ <entry file="file://$PROJECT_DIR$/flink-connectors/flink-connector-kera/src/main/java/org/apache/flink/streaming/connectors/kera/FlinkKeraConsumerBase.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="315">
+ <caret line="155" column="35" selection-start-line="155" selection-start-column="35" selection-end-line="155" selection-end-column="35" />
+ <folding>
+ <element signature="imports" expanded="true" />
+ </folding>
+ </state>
+ </provider>
+ </entry>
+ </file>
+ <file leaf-file-name="ExecutionGraphBuilder.java" pinned="false" current-in-tab="false">
+ <entry file="file://$PROJECT_DIR$/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraphBuilder.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="240">
+ <caret line="76" column="35" selection-start-line="76" selection-start-column="35" selection-end-line="76" selection-end-column="35" />
+ </state>
+ </provider>
+ </entry>
+ </file>
+ <file leaf-file-name="JobMaster.java" pinned="false" current-in-tab="false">
+ <entry file="file://$PROJECT_DIR$/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="2460">
+ <caret line="273" column="18" selection-start-line="273" selection-start-column="18" selection-end-line="273" selection-end-column="18" />
+ </state>
+ </provider>
+ </entry>
+ </file>
+ <file leaf-file-name="FlinkKeraConsumer.java" pinned="false" current-in-tab="false">
+ <entry file="file://$PROJECT_DIR$/flink-connectors/flink-connector-kera/src/main/java/org/apache/flink/streaming/connectors/kera/FlinkKeraConsumer.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="855">
+ <caret line="90" column="36" selection-start-line="90" selection-start-column="36" selection-end-line="90" selection-end-column="36" />
+ <folding>
+ <element signature="imports" expanded="true" />
+ </folding>
+ </state>
+ </provider>
+ </entry>
+ </file>
+ <file leaf-file-name="BenchSyntheticKeraPushRichConsStreaming.java" pinned="false" current-in-tab="false">
+ <entry file="file://$PROJECT_DIR$/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/kafka/BenchSyntheticKeraPushRichConsStreaming.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="540">
+ <caret line="69" column="66" lean-forward="true" selection-start-line="69" selection-start-column="66" selection-end-line="69" selection-end-column="66" />
+ </state>
+ </provider>
+ </entry>
+ </file>
+ <file leaf-file-name="SocketWindowWordCount.java" pinned="false" current-in-tab="false">
+ <entry file="file://$PROJECT_DIR$/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/socket/SocketWindowWordCount.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="855">
+ <caret line="79" column="23" lean-forward="true" selection-start-line="79" selection-start-column="23" selection-end-line="79" selection-end-column="23" />
+ <folding>
+ <element signature="e#0#3899#0" expanded="true" />
+ </folding>
+ </state>
+ </provider>
+ </entry>
+ </file>
+ <file leaf-file-name="DataStream.java" pinned="false" current-in-tab="false">
+ <entry file="file://$PROJECT_DIR$/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="2775">
+ <caret line="297" column="26" selection-start-line="297" selection-start-column="26" selection-end-line="297" selection-end-column="26" />
+ <folding>
+ <element signature="e#12326#12327#0" expanded="true" />
+ <element signature="e#12391#12392#0" expanded="true" />
+ </folding>
+ </state>
+ </provider>
+ </entry>
+ </file>
+ <file leaf-file-name="KeyedStream.java" pinned="false" current-in-tab="false">
+ <entry file="file://$PROJECT_DIR$/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="3780">
+ <caret line="324" column="19" selection-start-line="324" selection-start-column="19" selection-end-line="324" selection-end-column="19" />
+ <folding>
+ <element signature="e#0#34096#0" expanded="true" />
+ </folding>
+ </state>
+ </provider>
+ </entry>
+ </file>
+ <file leaf-file-name="WindowedStream.java" pinned="false" current-in-tab="false">
+ <entry file="file://$PROJECT_DIR$/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="450">
+ <caret line="105" lean-forward="true" selection-start-line="105" selection-end-line="105" />
+ </state>
+ </provider>
+ </entry>
+ </file>
+ <file leaf-file-name="PartitionInfo.java" pinned="false" current-in-tab="false">
+ <entry file="file://$PROJECT_DIR$/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/PartitionInfo.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="180">
+ <caret line="32" lean-forward="true" selection-start-line="32" selection-end-line="32" />
+ </state>
+ </provider>
+ </entry>
+ </file>
+ </leaf>
+ </component>
+ <component name="FindInProjectRecents">
+ <findStrings>
+ <find>standard</find>
+ <find>Standard</find>
+ <find>source</find>
+ <find>globalJobParameters</find>
+ </findStrings>
+ </component>
<component name="GradleLocalSettings">
<option name="modificationStamps">
<map>
@@ -16,6 +218,19 @@
</map>
</option>
</component>
+ <component name="IdeDocumentHistory">
+ <option name="CHANGED_PATHS">
+ <list>
+ <option value="$PROJECT_DIR$/flink-connectors/flink-connector-kera/src/main/java/org/apache/flink/streaming/connectors/kera/KeraSharedPushFetcher.java" />
+ <option value="$PROJECT_DIR$/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/kafka/BenchSyntheticKeraRichConsStreaming.java" />
+ <option value="$PROJECT_DIR$/flink-connectors/flink-connector-kera/src/main/java/org/apache/flink/streaming/connectors/kera/KeraFetcher.java" />
+ <option value="$PROJECT_DIR$/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/kafka/BenchSyntheticKeraPushRichConsStreaming.java" />
+ <option value="$PROJECT_DIR$/flink-connectors/flink-connector-kera/src/main/java/org/apache/flink/streaming/connectors/kera/FlinkKeraConsumerBase.java" />
+ <option value="$PROJECT_DIR$/flink-connectors/flink-connector-kera/src/main/java/org/apache/flink/streaming/connectors/kera/FlinkKeraSharedPushConsumer.java" />
+ <option value="$PROJECT_DIR$/flink-connectors/flink-connector-kera/src/main/java/org/apache/flink/streaming/connectors/kera/FlinkKeraConsumer.java" />
+ </list>
+ </option>
+ </component>
<component name="MavenImportPreferences">
<option name="importingSettings">
<MavenImportingSettings>
@@ -30,12 +245,383 @@
<option name="width" value="1291" />
<option name="height" value="837" />
</component>
+ <component name="ProjectView">
+ <navigator proportions="" version="1">
+ <foldersAlwaysOnTop value="true" />
+ </navigator>
+ <panes>
+ <pane id="AndroidView" />
+ <pane id="PackagesPane" />
+ <pane id="Scope" />
+ <pane id="ProjectPane">
+ <subPane>
+ <expand>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-connectors" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-connectors" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-connector-kafka-base" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-connectors" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-connector-kafka-base" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-connectors" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-connector-kafka-base" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-connectors" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-connector-kafka-base" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ <item name="java" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-connectors" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-connector-kafka-base" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ <item name="java" type="462c0819:PsiDirectoryNode" />
+ <item name="streaming" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-connectors" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-connector-kafka-base" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ <item name="java" type="462c0819:PsiDirectoryNode" />
+ <item name="streaming" type="462c0819:PsiDirectoryNode" />
+ <item name="serialization" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-connectors" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-connector-kera" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-connectors" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-connector-kera" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-connectors" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-connector-kera" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-connectors" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-connector-kera" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ <item name="java" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-connectors" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-connector-kera" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ <item name="java" type="462c0819:PsiDirectoryNode" />
+ <item name="kera" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-examples" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-examples" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-examples-streaming" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-examples" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-examples-streaming" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-examples" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-examples-streaming" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-examples" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-examples-streaming" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ <item name="java" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-examples" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-examples-streaming" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ <item name="java" type="462c0819:PsiDirectoryNode" />
+ <item name="examples" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-examples" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-examples-streaming" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ <item name="java" type="462c0819:PsiDirectoryNode" />
+ <item name="examples" type="462c0819:PsiDirectoryNode" />
+ <item name="kafka" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-runtime" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-runtime" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-runtime" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-runtime" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ <item name="java" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-runtime" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ <item name="java" type="462c0819:PsiDirectoryNode" />
+ <item name="flink" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-runtime" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ <item name="java" type="462c0819:PsiDirectoryNode" />
+ <item name="flink" type="462c0819:PsiDirectoryNode" />
+ <item name="runtime" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-runtime" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ <item name="java" type="462c0819:PsiDirectoryNode" />
+ <item name="flink" type="462c0819:PsiDirectoryNode" />
+ <item name="runtime" type="462c0819:PsiDirectoryNode" />
+ <item name="executiongraph" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-runtime" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ <item name="java" type="462c0819:PsiDirectoryNode" />
+ <item name="flink" type="462c0819:PsiDirectoryNode" />
+ <item name="runtime" type="462c0819:PsiDirectoryNode" />
+ <item name="jobgraph" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-streaming-java" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-streaming-java" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-streaming-java" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-streaming-java" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ <item name="java" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-streaming-java" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ <item name="java" type="462c0819:PsiDirectoryNode" />
+ <item name="flink" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-streaming-java" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ <item name="java" type="462c0819:PsiDirectoryNode" />
+ <item name="flink" type="462c0819:PsiDirectoryNode" />
+ <item name="streaming" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-streaming-java" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ <item name="java" type="462c0819:PsiDirectoryNode" />
+ <item name="flink" type="462c0819:PsiDirectoryNode" />
+ <item name="streaming" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-streaming-java" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ <item name="java" type="462c0819:PsiDirectoryNode" />
+ <item name="flink" type="462c0819:PsiDirectoryNode" />
+ <item name="streaming" type="462c0819:PsiDirectoryNode" />
+ <item name="api" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-streaming-java" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ <item name="java" type="462c0819:PsiDirectoryNode" />
+ <item name="flink" type="462c0819:PsiDirectoryNode" />
+ <item name="streaming" type="462c0819:PsiDirectoryNode" />
+ <item name="api" type="462c0819:PsiDirectoryNode" />
+ <item name="graph" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-streaming-java" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ <item name="java" type="462c0819:PsiDirectoryNode" />
+ <item name="flink" type="462c0819:PsiDirectoryNode" />
+ <item name="streaming" type="462c0819:PsiDirectoryNode" />
+ <item name="api" type="462c0819:PsiDirectoryNode" />
+ <item name="operators" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-streaming-java" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ <item name="java" type="462c0819:PsiDirectoryNode" />
+ <item name="flink" type="462c0819:PsiDirectoryNode" />
+ <item name="streaming" type="462c0819:PsiDirectoryNode" />
+ <item name="api" type="462c0819:PsiDirectoryNode" />
+ <item name="transformations" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-streaming-java" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ <item name="java" type="462c0819:PsiDirectoryNode" />
+ <item name="flink" type="462c0819:PsiDirectoryNode" />
+ <item name="streaming" type="462c0819:PsiDirectoryNode" />
+ <item name="util" type="462c0819:PsiDirectoryNode" />
+ </path>
+ <path>
+ <item name="flink-1.3.2" type="b2602c69:ProjectViewProjectNode" />
+ <item name="flink-1.3.2" type="462c0819:PsiDirectoryNode" />
+ <item name="flink-streaming-java" type="462c0819:PsiDirectoryNode" />
+ <item name="src" type="462c0819:PsiDirectoryNode" />
+ <item name="main" type="462c0819:PsiDirectoryNode" />
+ <item name="java" type="462c0819:PsiDirectoryNode" />
+ <item name="flink" type="462c0819:PsiDirectoryNode" />
+ <item name="streaming" type="462c0819:PsiDirectoryNode" />
+ <item name="util" type="462c0819:PsiDirectoryNode" />
+ <item name="serialization" type="462c0819:PsiDirectoryNode" />
+ </path>
+ </expand>
+ <select />
+ </subPane>
+ </pane>
+ </panes>
+ </component>
<component name="PropertiesComponent">
<property name="project.structure.last.edited" value="Modules" />
<property name="project.structure.proportion" value="0.0" />
<property name="project.structure.side.proportion" value="0.0" />
<property name="settings.editor.selected.configurable" value="preferences.sourceCode.Java" />
</component>
+ <component name="RecentsManager">
+ <key name="CopyClassDialog.RECENTS_KEY">
+ <recent name="org.apache.flink.streaming.examples.kafka" />
+ <recent name="org.apache.flink.streaming.connectors.kera" />
+ </key>
+ </component>
<component name="RunDashboard">
<option name="ruleStates">
<list>
@@ -125,38 +711,487 @@
<component name="ToolWindowManager">
<frame x="104" y="43" width="1291" height="837" extended-state="0" />
<layout>
- <window_info anchor="right" id="Palette" />
+ <window_info anchor="right" id="Palette" order="3" />
<window_info anchor="bottom" id="TODO" order="6" />
- <window_info anchor="right" id="Palette	" />
- <window_info id="Image Layers" />
- <window_info anchor="right" id="Capture Analysis" />
- <window_info anchor="bottom" id="Event Log" side_tool="true" />
- <window_info anchor="right" id="Maven Projects" />
+ <window_info anchor="right" id="Palette	" order="3" />
+ <window_info id="Image Layers" order="2" />
+ <window_info anchor="right" id="Capture Analysis" order="3" />
+ <window_info anchor="bottom" id="Event Log" order="7" side_tool="true" weight="0.32914925" />
+ <window_info anchor="right" id="Maven Projects" order="3" />
+ <window_info anchor="bottom" id="Version Control" order="7" show_stripe_button="false" />
<window_info anchor="bottom" id="Run" order="2" />
- <window_info anchor="bottom" id="Version Control" show_stripe_button="false" />
- <window_info anchor="bottom" id="Terminal" />
- <window_info id="Capture Tool" />
- <window_info id="Designer" />
- <window_info content_ui="combo" id="Project" order="0" weight="0.25" />
+ <window_info anchor="bottom" id="Terminal" order="7" />
+ <window_info id="Capture Tool" order="2" />
+ <window_info id="Designer" order="2" />
+ <window_info active="true" content_ui="combo" id="Project" order="0" visible="true" weight="0.1144916" />
<window_info id="Structure" order="1" side_tool="true" weight="0.25" />
<window_info anchor="right" id="Ant Build" order="1" weight="0.25" />
- <window_info id="UI Designer" />
- <window_info anchor="right" id="Theme Preview" />
+ <window_info id="UI Designer" order="2" />
+ <window_info anchor="right" id="Theme Preview" order="3" />
+ <window_info id="Favorites" order="2" side_tool="true" />
<window_info anchor="bottom" id="Debug" order="3" weight="0.4" />
- <window_info id="Favorites" side_tool="true" />
- <window_info anchor="bottom" id="Find" order="1" />
+ <window_info anchor="right" content_ui="combo" id="Hierarchy" order="2" weight="0.24979983" />
+ <window_info anchor="bottom" id="Inspection" order="5" weight="0.4" />
<window_info anchor="right" id="Commander" order="0" weight="0.4" />
<window_info anchor="bottom" id="Message" order="0" />
- <window_info anchor="bottom" id="Inspection" order="5" weight="0.4" />
- <window_info anchor="right" content_ui="combo" id="Hierarchy" order="2" weight="0.25" />
<window_info anchor="bottom" id="Cvs" order="4" weight="0.25" />
+ <window_info anchor="bottom" id="Find" order="1" weight="0.32914925" />
</layout>
</component>
<component name="VcsContentAnnotationSettings">
<option name="myLimit" value="2678400000" />
</component>
+ <component name="editorHistoryManager">
+ <entry file="file://$PROJECT_DIR$/flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer09.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="2505">
+ <caret line="209" column="86" selection-start-line="209" selection-start-column="57" selection-end-line="209" selection-end-column="86" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-core/src/main/java/org/apache/flink/configuration/Configuration.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="2595">
+ <caret line="215" column="15" selection-start-line="215" selection-start-column="15" selection-end-line="215" selection-end-column="15" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="jar:///Library/Java/JavaVirtualMachines/jdk1.7.0_80.jdk/Contents/Home/src.zip!/java/util/Map.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="229">
+ <caret line="312" column="11" selection-start-line="312" selection-start-column="11" selection-end-line="312" selection-end-column="11" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-connectors/flink-connector-kera/src/main/java/org/apache/flink/streaming/connectors/kera/KeraSharedPushFetcher.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="90">
+ <caret line="36" column="13" selection-start-line="36" selection-start-column="13" selection-end-line="36" selection-end-column="13" />
+ <folding>
+ <element signature="imports" expanded="true" />
+ </folding>
+ </state>
+ </provider>
+ </entry>
+ <entry file="jar://$MAVEN_REPOSITORY$/kera/ramcloud/1/ramcloud-1.jar!/edu/stanford/ramcloud/KeraHandoverSingleThread.class">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="225">
+ <caret line="226" column="27" selection-start-line="226" selection-start-column="27" selection-end-line="226" selection-end-column="27" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="jar://$MAVEN_REPOSITORY$/kera/ramcloud/1/ramcloud-1.jar!/edu/stanford/ramcloud/Streamlet.class">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="90">
+ <caret line="9" column="19" selection-start-line="9" selection-start-column="19" selection-end-line="9" selection-end-column="19" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-connectors/flink-connector-kera/src/main/java/org/apache/flink/streaming/connectors/kera/KeraFetcher.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="915">
+ <caret line="91" column="27" selection-start-line="91" selection-start-column="27" selection-end-line="91" selection-end-column="27" />
+ <folding>
+ <element signature="imports" expanded="true" />
+ </folding>
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-connectors/flink-connector-kera/src/main/java/org/apache/flink/streaming/connectors/kera/KeraTopicStreamletGroup.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="180">
+ <caret line="29" column="19" selection-start-line="29" selection-start-column="19" selection-end-line="29" selection-end-column="19" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-connectors/flink-connector-kera/src/main/java/org/apache/flink/streaming/connectors/kera/FlinkKeraSharedPushConsumer.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="825">
+ <caret line="71" selection-start-line="71" selection-end-line="71" />
+ <folding>
+ <element signature="imports" expanded="true" />
+ <element signature="e#2783#2794#0" expanded="true" />
+ </folding>
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-core/src/main/java/org/apache/flink/api/java/functions/KeySelector.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="127">
+ <caret line="35" column="17" selection-start-line="35" selection-start-column="17" selection-end-line="35" selection-end-column="17" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/generator/GraphGenerator.java">
+ <provider selected="true" editor-type-id="text-editor" />
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamSink.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="1020">
+ <caret line="92" column="78" lean-forward="true" selection-start-line="92" selection-start-column="78" selection-end-line="92" selection-end-column="78" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/SingleOutputStreamOperator.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="232">
+ <caret line="428" column="37" lean-forward="true" selection-start-line="428" selection-start-column="37" selection-end-line="428" selection-end-column="37" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="-225">
+ <caret line="37" column="36" selection-start-line="37" selection-start-column="36" selection-end-line="37" selection-end-column="36" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/StreamTransformation.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="232">
+ <caret line="100" column="22" selection-start-line="100" selection-start-column="22" selection-end-line="100" selection-end-column="22" />
+ <folding>
+ <element signature="e#10823#10824#0" expanded="true" />
+ <element signature="e#10853#10854#0" expanded="true" />
+ <element signature="e#11334#11335#0" expanded="true" />
+ <element signature="e#11381#11382#0" expanded="true" />
+ </folding>
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-streaming-java/src/main/java/org/apache/flink/migration/streaming/api/graph/StreamGraphHasherV1.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="407">
+ <caret line="261" column="64" selection-start-line="261" selection-start-column="64" selection-end-line="261" selection-end-column="64" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamIterationHead.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="165">
+ <caret line="36" column="13" selection-start-line="36" selection-start-column="13" selection-end-line="36" selection-end-column="13" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/FlinkPlan.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="75">
+ <caret line="21" column="46" lean-forward="true" selection-start-line="21" selection-start-column="26" selection-end-line="21" selection-end-column="46" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/StreamingPlan.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="150">
+ <caret line="29" column="51" selection-start-line="29" selection-start-column="51" selection-end-line="29" selection-end-column="51" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphHasher.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="135">
+ <caret line="26" column="17" selection-start-line="26" selection-start-column="17" selection-end-line="26" selection-end-column="17" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphHasherV2.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="322">
+ <caret line="161" column="54" selection-start-line="161" selection-start-column="54" selection-end-line="161" selection-end-column="54" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-core/src/main/java/org/apache/flink/api/common/operators/ResourceSpec.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="340">
+ <caret line="42" column="13" selection-start-line="42" selection-start-column="13" selection-end-line="42" selection-end-column="13" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="-4023">
+ <caret line="214" column="28" selection-start-line="214" selection-start-column="28" selection-end-line="214" selection-end-column="28" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/JSONGenerator.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="150">
+ <caret line="36" column="13" selection-start-line="36" selection-start-column="13" selection-end-line="36" selection-end-column="13" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/SourceTransformation.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="-151">
+ <caret line="33" column="13" selection-start-line="33" selection-start-column="13" selection-end-line="33" selection-end-column="13" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/PartitionTransformation.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="141">
+ <caret line="64" column="39" selection-start-line="64" selection-start-column="39" selection-end-line="64" selection-end-column="39" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="685">
+ <caret line="179" column="27" selection-start-line="179" selection-start-column="27" selection-end-line="179" selection-end-column="27" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/KeyContext.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="135">
+ <caret line="25" column="17" selection-start-line="25" selection-start-column="17" selection-end-line="25" selection-end-column="17" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/KeyedProcessOperator.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="-42">
+ <caret line="37" column="27" lean-forward="true" selection-start-line="37" selection-start-column="27" selection-end-line="37" selection-end-column="27" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="288">
+ <caret line="106" column="31" selection-start-line="106" selection-start-column="31" selection-end-line="106" selection-end-column="31" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/ChainingStrategy.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="90">
+ <caret line="32" column="12" selection-start-line="32" selection-start-column="12" selection-end-line="32" selection-end-column="12" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperator.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="279">
+ <caret line="45" column="27" selection-start-line="45" selection-start-column="27" selection-end-line="45" selection-end-column="27" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="16">
+ <caret line="75" column="17" lean-forward="true" selection-start-line="75" selection-start-column="17" selection-end-line="75" selection-end-column="17" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="323">
+ <caret line="251" column="30" selection-start-line="251" selection-start-column="30" selection-end-line="251" selection-end-column="30" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="328">
+ <caret line="90" column="21" selection-start-line="90" selection-start-column="21" selection-end-line="90" selection-end-column="21" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/IntermediateDataSet.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="-50">
+ <caret line="34" column="13" selection-start-line="34" selection-start-column="13" selection-end-line="34" selection-end-column="13" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="143">
+ <caret line="388" column="50" selection-start-line="388" selection-start-column="50" selection-end-line="388" selection-end-column="50" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="-468">
+ <caret line="375" column="16" selection-start-line="375" selection-start-column="16" selection-end-line="375" selection-end-column="16" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionAndSlot.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="135">
+ <caret line="28" column="13" selection-start-line="28" selection-start-column="13" selection-end-line="28" selection-end-column="13" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionEdge.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="60">
+ <caret line="20" column="13" selection-start-line="20" selection-start-column="13" selection-end-line="20" selection-end-column="13" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="291">
+ <caret line="637" column="15" lean-forward="true" selection-start-line="637" selection-start-column="15" selection-end-line="637" selection-end-column="15" />
+ <folding>
+ <element signature="e#25538#26118#0" expanded="true" />
+ <element signature="e#26117#26118#0" expanded="true" />
+ </folding>
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraphBuilder.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="240">
+ <caret line="76" column="35" selection-start-line="76" selection-start-column="35" selection-end-line="76" selection-end-column="35" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="2460">
+ <caret line="273" column="18" selection-start-line="273" selection-start-column="18" selection-end-line="273" selection-end-column="18" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/PartitionInfo.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="180">
+ <caret line="32" lean-forward="true" selection-start-line="32" selection-end-line="32" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="2775">
+ <caret line="297" column="26" selection-start-line="297" selection-start-column="26" selection-end-line="297" selection-end-column="26" />
+ <folding>
+ <element signature="e#12326#12327#0" expanded="true" />
+ <element signature="e#12391#12392#0" expanded="true" />
+ </folding>
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/socket/SocketWindowWordCount.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="855">
+ <caret line="79" column="23" lean-forward="true" selection-start-line="79" selection-start-column="23" selection-end-line="79" selection-end-column="23" />
+ <folding>
+ <element signature="e#0#3899#0" expanded="true" />
+ </folding>
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="3780">
+ <caret line="324" column="19" selection-start-line="324" selection-start-column="19" selection-end-line="324" selection-end-column="19" />
+ <folding>
+ <element signature="e#0#34096#0" expanded="true" />
+ </folding>
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="450">
+ <caret line="105" lean-forward="true" selection-start-line="105" selection-end-line="105" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/kafka/BenchSyntheticKeraPushRichConsStreaming.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="540">
+ <caret line="69" column="66" lean-forward="true" selection-start-line="69" selection-start-column="66" selection-end-line="69" selection-end-column="66" />
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-connectors/flink-connector-kera/src/main/java/org/apache/flink/streaming/connectors/kera/FlinkKeraConsumer.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="855">
+ <caret line="90" column="36" selection-start-line="90" selection-start-column="36" selection-end-line="90" selection-end-column="36" />
+ <folding>
+ <element signature="imports" expanded="true" />
+ </folding>
+ </state>
+ </provider>
+ </entry>
+ <entry file="file://$PROJECT_DIR$/flink-connectors/flink-connector-kera/src/main/java/org/apache/flink/streaming/connectors/kera/FlinkKeraConsumerBase.java">
+ <provider selected="true" editor-type-id="text-editor">
+ <state relative-caret-position="315">
+ <caret line="155" column="35" selection-start-line="155" selection-start-column="35" selection-end-line="155" selection-end-column="35" />
+ <folding>
+ <element signature="imports" expanded="true" />
+ </folding>
+ </state>
+ </provider>
+ </entry>
+ </component>
<component name="masterDetails">
<states>
+ <state key="ArtifactsStructureConfigurable.UI">
+ <settings>
+ <artifact-editor />
+ <splitter-proportions>
+ <option name="proportions">
+ <list>
+ <option value="0.2" />
+ </list>
+ </option>
+ </splitter-proportions>
+ </settings>
+ </state>
+ <state key="FacetStructureConfigurable.UI">
+ <settings>
+ <last-edited>No facets are configured</last-edited>
+ <splitter-proportions>
+ <option name="proportions">
+ <list>
+ <option value="0.2" />
+ </list>
+ </option>
+ </splitter-proportions>
+ </settings>
+ </state>
+ <state key="GlobalLibrariesConfigurable.UI">
+ <settings>
+ <splitter-proportions>
+ <option name="proportions">
+ <list>
+ <option value="0.2" />
+ </list>
+ </option>
+ </splitter-proportions>
+ </settings>
+ </state>
+ <state key="JdkListConfigurable.UI">
+ <settings>
+ <last-edited>1.7</last-edited>
+ <splitter-proportions>
+ <option name="proportions">
+ <list>
+ <option value="0.2" />
+ </list>
+ </option>
+ </splitter-proportions>
+ </settings>
+ </state>
+ <state key="ModuleStructureConfigurable.UI">
+ <settings>
+ <splitter-proportions>
+ <option name="proportions">
+ <list>
+ <option value="0.2" />
+ </list>
+ </option>
+ </splitter-proportions>
+ </settings>
+ </state>
<state key="ProjectJDKs.UI">
<settings>
<last-edited>1.7</last-edited>
@@ -169,6 +1204,17 @@
</splitter-proportions>
</settings>
</state>
+ <state key="ProjectLibrariesConfigurable.UI">
+ <settings>
+ <splitter-proportions>
+ <option name="proportions">
+ <list>
+ <option value="0.2" />
+ </list>
+ </option>
+ </splitter-proportions>
+ </settings>
+ </state>
</states>
</component>
</project>
\ No newline at end of file