Use the following commands to add the kubectl autocomplete to zsh:
mkdir -p ~/.oh-my-zsh/custom/plugins/kubectl-autocomplete/
kubectl completion zsh > ~/.oh-my-zsh/custom/plugins/kubectl-autocomplete/kubectl-autocomplete.plugin.zsh| public static void main(String[] args) throws Exception { | |
| final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); | |
| DataStream<Tuple1<String>> stream = ... | |
| DataStream<Tuple1<String>> filters = ... | |
| stream | |
| .keyBy(0) | |
| .connect(filters.keyBy(0)) // partition both streams on same field and connect them | |
| .flatMap(new StreamFilter()) // apply CoFlatMap function to update filters and to filter data |