Skip to content

Instantly share code, notes, and snippets.

import React, { Component } from 'react';
import { reduxForm, Field } from 'redux-form';
import { Form, Button, Label, Input } from 'semantic-ui-react';
const CustomInput = ({ input, meta: { error, touched }, label, ...custom }) => (
<Form.Field error={error && touched}>
<label htmlFor={custom.name} >{label}</label>
<Input id={custom.name} {...input} {...custom} />
{error && touched && <Label basic color="red" pointing>{error}</Label>}
</Form.Field>
import java.util.Properties;
import org.apache.flink.api.common.functions.FoldFunction;
import org.apache.flink.api.common.functions.RichMapFunction;
import org.apache.flink.api.java.functions.KeySelector;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.functions.source.SourceFunction;
import org.apache.flink.streaming.api.windowing.time.Time;
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer082;
import org.apache.flink.streaming.util.serialization.SimpleStringSchema;
import org.apache.kafka.clients.consumer.ConsumerConfig;
009
0505089030646397
0505089030658153
0505089032919227
0505089053108379
0505089061414
0505089061414084
05050890614141084
0505089063119615
0505089063249188
112
115
116
119
120
126
127
134
135
137
< 252
< 273
< 275
< 285
< 354
< 366
< 379
< 447
< 463
< 534
112
115
116
119
120
126
127
134
135
137
115
152
252
271
273
275
285
301
354
366
101
103
105
106
107
108
109
112
113
114
101
108
119
120
123
126
131
133
136
137
101
108
119
120
123
126
131
133
136
137