Skip to content

Commit 371196c

Browse files
mjsaxmjsax
committed
Fix license headers
1 parent 66a9fa7 commit 371196c

File tree

80 files changed

+1036
-854
lines changed

Some content is hidden

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

80 files changed

+1036
-854
lines changed

‎src/main/java/io/confluent/examples/streams/AnomalyDetectionLambdaExample.java

+14-12
Original file line numberDiff line numberDiff line change
@@ -1,15 +1,17 @@
1-
/**
2-
* Copyright 2016 Confluent Inc.
3-
* <p>
4-
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
5-
* in compliance with the License. You may obtain a copy of the License at
6-
* <p>
7-
* http://www.apache.org/licenses/LICENSE-2.0
8-
* <p>
9-
* Unless required by applicable law or agreed to in writing, software distributed under the License
10-
* is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
11-
* or implied. See the License for the specific language governing permissions and limitations under
12-
* the License.
1+
/*
2+
* Copyright Confluent Inc.
3+
*
4+
* Licensed under the Apache License, Version 2.0 (the "License");
5+
* you may not use this file except in compliance with the License.
6+
* You may obtain a copy of the License at
7+
*
8+
* http://www.apache.org/licenses/LICENSE-2.0
9+
*
10+
* Unless required by applicable law or agreed to in writing, software
11+
* distributed under the License is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
* See the License for the specific language governing permissions and
14+
* limitations under the License.
1315
*/
1416
package io.confluent.examples.streams;
1517

‎src/main/java/io/confluent/examples/streams/ApplicationResetExample.java

+15-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,20 @@
1+
/*
2+
* Copyright Confluent Inc.
3+
*
4+
* Licensed under the Apache License, Version 2.0 (the "License");
5+
* you may not use this file except in compliance with the License.
6+
* You may obtain a copy of the License at
7+
*
8+
* http://www.apache.org/licenses/LICENSE-2.0
9+
*
10+
* Unless required by applicable law or agreed to in writing, software
11+
* distributed under the License is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
* See the License for the specific language governing permissions and
14+
* limitations under the License.
15+
*/
116
package io.confluent.examples.streams;
217

3-
418
import org.apache.kafka.clients.consumer.ConsumerConfig;
519
import org.apache.kafka.common.serialization.Serdes;
620
import org.apache.kafka.streams.KafkaStreams;

‎src/main/java/io/confluent/examples/streams/GlobalKTablesExample.java

+20-19
Original file line numberDiff line numberDiff line change
@@ -1,18 +1,26 @@
1-
/**
2-
* Copyright 2016 Confluent Inc.
3-
* <p>
4-
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
5-
* in compliance with the License. You may obtain a copy of the License at
6-
* <p>
7-
* http://www.apache.org/licenses/LICENSE-2.0
8-
* <p>
9-
* Unless required by applicable law or agreed to in writing, software distributed under the License
10-
* is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
11-
* or implied. See the License for the specific language governing permissions and limitations under
12-
* the License.
1+
/*
2+
* Copyright Confluent Inc.
3+
*
4+
* Licensed under the Apache License, Version 2.0 (the "License");
5+
* you may not use this file except in compliance with the License.
6+
* You may obtain a copy of the License at
7+
*
8+
* http://www.apache.org/licenses/LICENSE-2.0
9+
*
10+
* Unless required by applicable law or agreed to in writing, software
11+
* distributed under the License is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
* See the License for the specific language governing permissions and
14+
* limitations under the License.
1315
*/
1416
package io.confluent.examples.streams;
1517

18+
import io.confluent.examples.streams.avro.Customer;
19+
import io.confluent.examples.streams.avro.EnrichedOrder;
20+
import io.confluent.examples.streams.avro.Order;
21+
import io.confluent.examples.streams.avro.Product;
22+
import io.confluent.kafka.serializers.AbstractKafkaAvroSerDeConfig;
23+
import io.confluent.kafka.streams.serdes.avro.SpecificAvroSerde;
1624
import org.apache.kafka.clients.consumer.ConsumerConfig;
1725
import org.apache.kafka.common.serialization.Serdes;
1826
import org.apache.kafka.streams.KafkaStreams;
@@ -25,13 +33,6 @@
2533
import java.util.Map;
2634
import java.util.Properties;
2735

28-
import io.confluent.examples.streams.avro.Customer;
29-
import io.confluent.examples.streams.avro.EnrichedOrder;
30-
import io.confluent.examples.streams.avro.Order;
31-
import io.confluent.examples.streams.avro.Product;
32-
import io.confluent.kafka.serializers.AbstractKafkaAvroSerDeConfig;
33-
import io.confluent.kafka.streams.serdes.avro.SpecificAvroSerde;
34-
3536
/**
3637
* Demonstrates how to perform joins between KStreams and GlobalKTables, i.e. joins that
3738
* don't require re-partitioning of the input streams.

‎src/main/java/io/confluent/examples/streams/GlobalKTablesExampleDriver.java

+22-21
Original file line numberDiff line numberDiff line change
@@ -1,18 +1,28 @@
1-
/**
2-
* Copyright 2016 Confluent Inc.
3-
* <p>
4-
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
5-
* in compliance with the License. You may obtain a copy of the License at
6-
* <p>
7-
* http://www.apache.org/licenses/LICENSE-2.0
8-
* <p>
9-
* Unless required by applicable law or agreed to in writing, software distributed under the License
10-
* is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
11-
* or implied. See the License for the specific language governing permissions and limitations under
12-
* the License.
1+
/*
2+
* Copyright Confluent Inc.
3+
*
4+
* Licensed under the Apache License, Version 2.0 (the "License");
5+
* you may not use this file except in compliance with the License.
6+
* You may obtain a copy of the License at
7+
*
8+
* http://www.apache.org/licenses/LICENSE-2.0
9+
*
10+
* Unless required by applicable law or agreed to in writing, software
11+
* distributed under the License is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
* See the License for the specific language governing permissions and
14+
* limitations under the License.
1315
*/
1416
package io.confluent.examples.streams;
1517

18+
import io.confluent.examples.streams.avro.Customer;
19+
import io.confluent.examples.streams.avro.EnrichedOrder;
20+
import io.confluent.examples.streams.avro.Order;
21+
import io.confluent.examples.streams.avro.Product;
22+
import io.confluent.kafka.serializers.AbstractKafkaAvroSerDeConfig;
23+
import io.confluent.kafka.serializers.KafkaAvroDeserializer;
24+
import io.confluent.kafka.serializers.KafkaAvroDeserializerConfig;
25+
import io.confluent.kafka.streams.serdes.avro.SpecificAvroSerde;
1626
import org.apache.avro.specific.SpecificRecord;
1727
import org.apache.kafka.clients.consumer.ConsumerConfig;
1828
import org.apache.kafka.clients.consumer.ConsumerRecords;
@@ -29,15 +39,6 @@
2939
import java.util.Properties;
3040
import java.util.Random;
3141

32-
import io.confluent.examples.streams.avro.Customer;
33-
import io.confluent.examples.streams.avro.EnrichedOrder;
34-
import io.confluent.examples.streams.avro.Order;
35-
import io.confluent.examples.streams.avro.Product;
36-
import io.confluent.kafka.serializers.AbstractKafkaAvroSerDeConfig;
37-
import io.confluent.kafka.serializers.KafkaAvroDeserializer;
38-
import io.confluent.kafka.serializers.KafkaAvroDeserializerConfig;
39-
import io.confluent.kafka.streams.serdes.avro.SpecificAvroSerde;
40-
4142
import static io.confluent.examples.streams.GlobalKTablesExample.CUSTOMER_TOPIC;
4243
import static io.confluent.examples.streams.GlobalKTablesExample.ENRICHED_ORDER_TOPIC;
4344
import static io.confluent.examples.streams.GlobalKTablesExample.ORDER_TOPIC;

‎src/main/java/io/confluent/examples/streams/MapFunctionLambdaExample.java

+14-12
Original file line numberDiff line numberDiff line change
@@ -1,15 +1,17 @@
1-
/**
2-
* Copyright 2016 Confluent Inc.
3-
* <p>
4-
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
5-
* in compliance with the License. You may obtain a copy of the License at
6-
* <p>
7-
* http://www.apache.org/licenses/LICENSE-2.0
8-
* <p>
9-
* Unless required by applicable law or agreed to in writing, software distributed under the License
10-
* is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
11-
* or implied. See the License for the specific language governing permissions and limitations under
12-
* the License.
1+
/*
2+
* Copyright Confluent Inc.
3+
*
4+
* Licensed under the Apache License, Version 2.0 (the "License");
5+
* you may not use this file except in compliance with the License.
6+
* You may obtain a copy of the License at
7+
*
8+
* http://www.apache.org/licenses/LICENSE-2.0
9+
*
10+
* Unless required by applicable law or agreed to in writing, software
11+
* distributed under the License is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
* See the License for the specific language governing permissions and
14+
* limitations under the License.
1315
*/
1416
package io.confluent.examples.streams;
1517

‎src/main/java/io/confluent/examples/streams/PageViewRegionExample.java

+16-15
Original file line numberDiff line numberDiff line change
@@ -1,18 +1,22 @@
1-
/**
2-
* Copyright 2016 Confluent Inc.
3-
* <p>
4-
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
5-
* in compliance with the License. You may obtain a copy of the License at
6-
* <p>
7-
* http://www.apache.org/licenses/LICENSE-2.0
8-
* <p>
9-
* Unless required by applicable law or agreed to in writing, software distributed under the License
10-
* is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
11-
* or implied. See the License for the specific language governing permissions and limitations under
12-
* the License.
1+
/*
2+
* Copyright Confluent Inc.
3+
*
4+
* Licensed under the Apache License, Version 2.0 (the "License");
5+
* you may not use this file except in compliance with the License.
6+
* You may obtain a copy of the License at
7+
*
8+
* http://www.apache.org/licenses/LICENSE-2.0
9+
*
10+
* Unless required by applicable law or agreed to in writing, software
11+
* distributed under the License is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
* See the License for the specific language governing permissions and
14+
* limitations under the License.
1315
*/
1416
package io.confluent.examples.streams;
1517

18+
import io.confluent.kafka.serializers.AbstractKafkaAvroSerDeConfig;
19+
import io.confluent.kafka.streams.serdes.avro.GenericAvroSerde;
1620
import org.apache.avro.Schema;
1721
import org.apache.avro.generic.GenericData;
1822
import org.apache.avro.generic.GenericRecord;
@@ -34,9 +38,6 @@
3438
import java.io.InputStream;
3539
import java.util.Properties;
3640

37-
import io.confluent.kafka.serializers.AbstractKafkaAvroSerDeConfig;
38-
import io.confluent.kafka.streams.serdes.avro.GenericAvroSerde;
39-
4041
/**
4142
* Demonstrates how to perform a join between a KStream and a KTable, i.e. an example of a stateful
4243
* computation, using the generic Avro binding for serdes in Kafka Streams. Same as

‎src/main/java/io/confluent/examples/streams/PageViewRegionExampleDriver.java

+15-14
Original file line numberDiff line numberDiff line change
@@ -1,18 +1,21 @@
1-
/**
2-
* Copyright 2016 Confluent Inc.
3-
* <p>
4-
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
5-
* in compliance with the License. You may obtain a copy of the License at
6-
* <p>
7-
* http://www.apache.org/licenses/LICENSE-2.0
8-
* <p>
9-
* Unless required by applicable law or agreed to in writing, software distributed under the License
10-
* is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
11-
* or implied. See the License for the specific language governing permissions and limitations under
12-
* the License.
1+
/*
2+
* Copyright Confluent Inc.
3+
*
4+
* Licensed under the Apache License, Version 2.0 (the "License");
5+
* you may not use this file except in compliance with the License.
6+
* You may obtain a copy of the License at
7+
*
8+
* http://www.apache.org/licenses/LICENSE-2.0
9+
*
10+
* Unless required by applicable law or agreed to in writing, software
11+
* distributed under the License is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
* See the License for the specific language governing permissions and
14+
* limitations under the License.
1315
*/
1416
package io.confluent.examples.streams;
1517

18+
import io.confluent.kafka.serializers.AbstractKafkaAvroSerDeConfig;
1619
import org.apache.avro.Schema;
1720
import org.apache.avro.generic.GenericRecord;
1821
import org.apache.avro.generic.GenericRecordBuilder;
@@ -34,8 +37,6 @@
3437
import java.util.Random;
3538
import java.util.stream.IntStream;
3639

37-
import io.confluent.kafka.serializers.AbstractKafkaAvroSerDeConfig;
38-
3940
/**
4041
* This is a sample driver for the {@link PageViewRegionExample} and {@link PageViewRegionLambdaExample}.
4142
* To run this driver please first refer to the instructions in {@link PageViewRegionExample} or {@link PageViewRegionLambdaExample}.

‎src/main/java/io/confluent/examples/streams/PageViewRegionLambdaExample.java

+16-15
Original file line numberDiff line numberDiff line change
@@ -1,18 +1,22 @@
1-
/**
2-
* Copyright 2016 Confluent Inc.
3-
* <p>
4-
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
5-
* in compliance with the License. You may obtain a copy of the License at
6-
* <p>
7-
* http://www.apache.org/licenses/LICENSE-2.0
8-
* <p>
9-
* Unless required by applicable law or agreed to in writing, software distributed under the License
10-
* is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
11-
* or implied. See the License for the specific language governing permissions and limitations under
12-
* the License.
1+
/*
2+
* Copyright Confluent Inc.
3+
*
4+
* Licensed under the Apache License, Version 2.0 (the "License");
5+
* you may not use this file except in compliance with the License.
6+
* You may obtain a copy of the License at
7+
*
8+
* http://www.apache.org/licenses/LICENSE-2.0
9+
*
10+
* Unless required by applicable law or agreed to in writing, software
11+
* distributed under the License is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
* See the License for the specific language governing permissions and
14+
* limitations under the License.
1315
*/
1416
package io.confluent.examples.streams;
1517

18+
import io.confluent.kafka.serializers.AbstractKafkaAvroSerDeConfig;
19+
import io.confluent.kafka.streams.serdes.avro.GenericAvroSerde;
1620
import org.apache.avro.Schema;
1721
import org.apache.avro.generic.GenericData;
1822
import org.apache.avro.generic.GenericRecord;
@@ -31,9 +35,6 @@
3135
import java.io.InputStream;
3236
import java.util.Properties;
3337

34-
import io.confluent.kafka.serializers.AbstractKafkaAvroSerDeConfig;
35-
import io.confluent.kafka.streams.serdes.avro.GenericAvroSerde;
36-
3738
/**
3839
* Demonstrates how to perform a join between a KStream and a KTable, i.e. an example of a stateful
3940
* computation, using the generic Avro binding for serdes in Kafka Streams. Same as

‎src/main/java/io/confluent/examples/streams/SecureKafkaStreamsExample.java

+10-8
Original file line numberDiff line numberDiff line change
@@ -1,15 +1,17 @@
11
/*
2-
* Copyright 2016 Confluent Inc.
2+
* Copyright Confluent Inc.
33
*
4-
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
5-
* in compliance with the License. You may obtain a copy of the License at
4+
* Licensed under the Apache License, Version 2.0 (the "License");
5+
* you may not use this file except in compliance with the License.
6+
* You may obtain a copy of the License at
67
*
7-
* http://www.apache.org/licenses/LICENSE-2.0
8+
* http://www.apache.org/licenses/LICENSE-2.0
89
*
9-
* Unless required by applicable law or agreed to in writing, software distributed under the License
10-
* is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
11-
* or implied. See the License for the specific language governing permissions and limitations under
12-
* the License.
10+
* Unless required by applicable law or agreed to in writing, software
11+
* distributed under the License is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
* See the License for the specific language governing permissions and
14+
* limitations under the License.
1315
*/
1416
package io.confluent.examples.streams;
1517

‎src/main/java/io/confluent/examples/streams/SessionWindowsExample.java

+10-12
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,11 @@
1-
/**
2-
* Licensed to the Apache Software Foundation (ASF) under one or more
3-
* contributor license agreements. See the NOTICE file distributed with
4-
* this work for additional information regarding copyright ownership.
5-
* The ASF licenses this file to You under the Apache License, Version 2.0
6-
* (the "License"); you may not use this file except in compliance with
7-
* the License. You may obtain a copy of the License at
1+
/*
2+
* Copyright Confluent Inc.
3+
*
4+
* Licensed under the Apache License, Version 2.0 (the "License");
5+
* you may not use this file except in compliance with the License.
6+
* You may obtain a copy of the License at
87
*
9-
* http://www.apache.org/licenses/LICENSE-2.0
8+
* http://www.apache.org/licenses/LICENSE-2.0
109
*
1110
* Unless required by applicable law or agreed to in writing, software
1211
* distributed under the License is distributed on an "AS IS" BASIS,
@@ -16,6 +15,9 @@
1615
*/
1716
package io.confluent.examples.streams;
1817

18+
import io.confluent.examples.streams.avro.PlayEvent;
19+
import io.confluent.kafka.serializers.AbstractKafkaAvroSerDeConfig;
20+
import io.confluent.kafka.streams.serdes.avro.SpecificAvroSerde;
1921
import org.apache.kafka.clients.consumer.ConsumerConfig;
2022
import org.apache.kafka.common.serialization.Serdes;
2123
import org.apache.kafka.streams.KafkaStreams;
@@ -29,10 +31,6 @@
2931
import java.util.Properties;
3032
import java.util.concurrent.TimeUnit;
3133

32-
import io.confluent.examples.streams.avro.PlayEvent;
33-
import io.confluent.kafka.serializers.AbstractKafkaAvroSerDeConfig;
34-
import io.confluent.kafka.streams.serdes.avro.SpecificAvroSerde;
35-
3634
/**
3735
* Demonstrates counting user activity (play-events) into Session Windows
3836
* <p>

0 commit comments

Comments
 (0)