diff --git a/function-samples/http-ingest/.mvn/wrapper/maven-wrapper.jar b/function-samples/http-click-ingest/.mvn/wrapper/maven-wrapper.jar similarity index 100% rename from function-samples/http-ingest/.mvn/wrapper/maven-wrapper.jar rename to function-samples/http-click-ingest/.mvn/wrapper/maven-wrapper.jar diff --git a/function-samples/http-ingest/.mvn/wrapper/maven-wrapper.properties b/function-samples/http-click-ingest/.mvn/wrapper/maven-wrapper.properties similarity index 100% rename from function-samples/http-ingest/.mvn/wrapper/maven-wrapper.properties rename to function-samples/http-click-ingest/.mvn/wrapper/maven-wrapper.properties diff --git a/function-samples/http-ingest/README.adoc b/function-samples/http-click-ingest/README.adoc similarity index 100% rename from function-samples/http-ingest/README.adoc rename to function-samples/http-click-ingest/README.adoc diff --git a/function-samples/http-ingest/mvnw b/function-samples/http-click-ingest/mvnw similarity index 100% rename from function-samples/http-ingest/mvnw rename to function-samples/http-click-ingest/mvnw diff --git a/function-samples/http-ingest/mvnw.cmd b/function-samples/http-click-ingest/mvnw.cmd similarity index 100% rename from function-samples/http-ingest/mvnw.cmd rename to function-samples/http-click-ingest/mvnw.cmd diff --git a/function-samples/http-ingest/pom.xml b/function-samples/http-click-ingest/pom.xml similarity index 66% rename from function-samples/http-ingest/pom.xml rename to function-samples/http-click-ingest/pom.xml index 0abfd72..9954398 100644 --- a/function-samples/http-ingest/pom.xml +++ b/function-samples/http-click-ingest/pom.xml @@ -10,7 +10,7 @@ org.springframework.cloud.dataflow.samples http-click-ingest - 1.0.0.BUILD-SNAPSHOT + 1.0.1.BUILD-SNAPSHOT http-ingest Http click ingest application @@ -74,4 +74,49 @@ + + + + spring-snapshots + Spring Snapshots + https://repo.spring.io/libs-snapshot + + true + + + + spring-milestones + Spring Milestones + https://repo.spring.io/libs-milestone-local + + false + + + + spring-releases + Spring Releases + https://repo.spring.io/release + + false + + + + + + spring-snapshots + Spring Snapshots + https://repo.spring.io/libs-snapshot-local + + true + + + + spring-milestones + Spring Milestones + https://repo.spring.io/libs-milestone-local + + false + + + diff --git a/function-samples/http-ingest/src/main/java/org/springframework/cloud/dataflow/samples/source/HttpIngest.java b/function-samples/http-click-ingest/src/main/java/org/springframework/cloud/dataflow/samples/source/HttpIngest.java similarity index 100% rename from function-samples/http-ingest/src/main/java/org/springframework/cloud/dataflow/samples/source/HttpIngest.java rename to function-samples/http-click-ingest/src/main/java/org/springframework/cloud/dataflow/samples/source/HttpIngest.java diff --git a/function-samples/http-ingest/src/main/resources/META-INF/dataflow-configuration-metadata-whitelist.properties b/function-samples/http-click-ingest/src/main/resources/META-INF/dataflow-configuration-metadata-whitelist.properties similarity index 100% rename from function-samples/http-ingest/src/main/resources/META-INF/dataflow-configuration-metadata-whitelist.properties rename to function-samples/http-click-ingest/src/main/resources/META-INF/dataflow-configuration-metadata-whitelist.properties diff --git a/function-samples/http-ingest/src/main/resources/application.properties b/function-samples/http-click-ingest/src/main/resources/application.properties similarity index 100% rename from function-samples/http-ingest/src/main/resources/application.properties rename to function-samples/http-click-ingest/src/main/resources/application.properties diff --git a/function-samples/http-ingest/src/main/resources/application.yml b/function-samples/http-click-ingest/src/main/resources/application.yml similarity index 100% rename from function-samples/http-ingest/src/main/resources/application.yml rename to function-samples/http-click-ingest/src/main/resources/application.yml diff --git a/function-samples/http-region-ingest/pom.xml b/function-samples/http-region-ingest/pom.xml index cd2d89f..9ae62e4 100644 --- a/function-samples/http-region-ingest/pom.xml +++ b/function-samples/http-region-ingest/pom.xml @@ -10,7 +10,7 @@ org.springframework.cloud.dataflow.samples http-region-ingest - 1.0.0.BUILD-SNAPSHOT + 1.0.1.BUILD-SNAPSHOT http-region-ingest Http region ingest application @@ -74,4 +74,49 @@ + + + + spring-snapshots + Spring Snapshots + https://repo.spring.io/libs-snapshot + + true + + + + spring-milestones + Spring Milestones + https://repo.spring.io/libs-milestone-local + + false + + + + spring-releases + Spring Releases + https://repo.spring.io/release + + false + + + + + + spring-snapshots + Spring Snapshots + https://repo.spring.io/libs-snapshot-local + + true + + + + spring-milestones + Spring Milestones + https://repo.spring.io/libs-milestone-local + + false + + + diff --git a/function-samples/kstreams-join-user-clicks-and-region/pom.xml b/function-samples/kstreams-join-user-clicks-and-region/pom.xml index dbc8848..14ee2b2 100644 --- a/function-samples/kstreams-join-user-clicks-and-region/pom.xml +++ b/function-samples/kstreams-join-user-clicks-and-region/pom.xml @@ -11,7 +11,7 @@ org.springframework.cloud.dataflow.samples kstreams-join-user-clicks-and-region - 1.0.0.BUILD-SNAPSHOT + 1.0.1.BUILD-SNAPSHOT jar kstreams-join-user-clicks-and-region @@ -69,4 +69,48 @@ + + + spring-snapshots + Spring Snapshots + https://repo.spring.io/libs-snapshot + + true + + + + spring-milestones + Spring Milestones + https://repo.spring.io/libs-milestone-local + + false + + + + spring-releases + Spring Releases + https://repo.spring.io/release + + false + + + + + + spring-snapshots + Spring Snapshots + https://repo.spring.io/libs-snapshot-local + + true + + + + spring-milestones + Spring Milestones + https://repo.spring.io/libs-milestone-local + + false + + + diff --git a/function-samples/kstreams-log-user-clicks-per-region/pom.xml b/function-samples/kstreams-log-user-clicks-per-region/pom.xml index 0061687..ced1ab5 100644 --- a/function-samples/kstreams-log-user-clicks-per-region/pom.xml +++ b/function-samples/kstreams-log-user-clicks-per-region/pom.xml @@ -10,7 +10,7 @@ org.springframework.cloud.dataflow.samples kstreams-log-user-clicks-per-region - 1.0.0.BUILD-SNAPSHOT + 1.0.1.BUILD-SNAPSHOT kstreams-log-user-clicks-per-region @@ -64,4 +64,49 @@ + + + spring-snapshots + Spring Snapshots + https://repo.spring.io/libs-snapshot + + true + + + + spring-milestones + Spring Milestones + https://repo.spring.io/libs-milestone-local + + false + + + + spring-releases + Spring Releases + https://repo.spring.io/release + + false + + + + + + spring-snapshots + Spring Snapshots + https://repo.spring.io/libs-snapshot-local + + true + + + + spring-milestones + Spring Milestones + https://repo.spring.io/libs-milestone-local + + false + + + + diff --git a/function-samples/kstreams-word-count/.gitignore b/function-samples/kstreams-word-count/.gitignore deleted file mode 100644 index 2af7cef..0000000 --- a/function-samples/kstreams-word-count/.gitignore +++ /dev/null @@ -1,24 +0,0 @@ -target/ -!.mvn/wrapper/maven-wrapper.jar - -### STS ### -.apt_generated -.classpath -.factorypath -.project -.settings -.springBeans - -### IntelliJ IDEA ### -.idea -*.iws -*.iml -*.ipr - -### NetBeans ### -nbproject/private/ -build/ -nbbuild/ -dist/ -nbdist/ -.nb-gradle/ \ No newline at end of file diff --git a/function-samples/kstreams-word-count/.mvn/wrapper/maven-wrapper.jar b/function-samples/kstreams-word-count/.mvn/wrapper/maven-wrapper.jar deleted file mode 100644 index 9cc84ea..0000000 Binary files a/function-samples/kstreams-word-count/.mvn/wrapper/maven-wrapper.jar and /dev/null differ diff --git a/function-samples/kstreams-word-count/.mvn/wrapper/maven-wrapper.properties b/function-samples/kstreams-word-count/.mvn/wrapper/maven-wrapper.properties deleted file mode 100644 index c315043..0000000 --- a/function-samples/kstreams-word-count/.mvn/wrapper/maven-wrapper.properties +++ /dev/null @@ -1 +0,0 @@ -distributionUrl=https://repo1.maven.org/maven2/org/apache/maven/apache-maven/3.5.0/apache-maven-3.5.0-bin.zip diff --git a/function-samples/kstreams-word-count/mvnw b/function-samples/kstreams-word-count/mvnw deleted file mode 100755 index 5bf251c..0000000 --- a/function-samples/kstreams-word-count/mvnw +++ /dev/null @@ -1,225 +0,0 @@ -#!/bin/sh -# ---------------------------------------------------------------------------- -# Licensed to the Apache Software Foundation (ASF) under one -# or more contributor license agreements. See the NOTICE file -# distributed with this work for additional information -# regarding copyright ownership. The ASF licenses this file -# to you under the Apache License, Version 2.0 (the -# "License"); you may not use this file except in compliance -# with the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, -# software distributed under the License is distributed on an -# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -# KIND, either express or implied. See the License for the -# specific language governing permissions and limitations -# under the License. -# ---------------------------------------------------------------------------- - -# ---------------------------------------------------------------------------- -# Maven2 Start Up Batch script -# -# Required ENV vars: -# ------------------ -# JAVA_HOME - location of a JDK home dir -# -# Optional ENV vars -# ----------------- -# M2_HOME - location of maven2's installed home dir -# MAVEN_OPTS - parameters passed to the Java VM when running Maven -# e.g. to debug Maven itself, use -# set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000 -# MAVEN_SKIP_RC - flag to disable loading of mavenrc files -# ---------------------------------------------------------------------------- - -if [ -z "$MAVEN_SKIP_RC" ] ; then - - if [ -f /etc/mavenrc ] ; then - . /etc/mavenrc - fi - - if [ -f "$HOME/.mavenrc" ] ; then - . "$HOME/.mavenrc" - fi - -fi - -# OS specific support. $var _must_ be set to either true or false. -cygwin=false; -darwin=false; -mingw=false -case "`uname`" in - CYGWIN*) cygwin=true ;; - MINGW*) mingw=true;; - Darwin*) darwin=true - # Use /usr/libexec/java_home if available, otherwise fall back to /Library/Java/Home - # See https://developer.apple.com/library/mac/qa/qa1170/_index.html - if [ -z "$JAVA_HOME" ]; then - if [ -x "/usr/libexec/java_home" ]; then - export JAVA_HOME="`/usr/libexec/java_home`" - else - export JAVA_HOME="/Library/Java/Home" - fi - fi - ;; -esac - -if [ -z "$JAVA_HOME" ] ; then - if [ -r /etc/gentoo-release ] ; then - JAVA_HOME=`java-config --jre-home` - fi -fi - -if [ -z "$M2_HOME" ] ; then - ## resolve links - $0 may be a link to maven's home - PRG="$0" - - # need this for relative symlinks - while [ -h "$PRG" ] ; do - ls=`ls -ld "$PRG"` - link=`expr "$ls" : '.*-> \(.*\)$'` - if expr "$link" : '/.*' > /dev/null; then - PRG="$link" - else - PRG="`dirname "$PRG"`/$link" - fi - done - - saveddir=`pwd` - - M2_HOME=`dirname "$PRG"`/.. - - # make it fully qualified - M2_HOME=`cd "$M2_HOME" && pwd` - - cd "$saveddir" - # echo Using m2 at $M2_HOME -fi - -# For Cygwin, ensure paths are in UNIX format before anything is touched -if $cygwin ; then - [ -n "$M2_HOME" ] && - M2_HOME=`cygpath --unix "$M2_HOME"` - [ -n "$JAVA_HOME" ] && - JAVA_HOME=`cygpath --unix "$JAVA_HOME"` - [ -n "$CLASSPATH" ] && - CLASSPATH=`cygpath --path --unix "$CLASSPATH"` -fi - -# For Migwn, ensure paths are in UNIX format before anything is touched -if $mingw ; then - [ -n "$M2_HOME" ] && - M2_HOME="`(cd "$M2_HOME"; pwd)`" - [ -n "$JAVA_HOME" ] && - JAVA_HOME="`(cd "$JAVA_HOME"; pwd)`" - # TODO classpath? -fi - -if [ -z "$JAVA_HOME" ]; then - javaExecutable="`which javac`" - if [ -n "$javaExecutable" ] && ! [ "`expr \"$javaExecutable\" : '\([^ ]*\)'`" = "no" ]; then - # readlink(1) is not available as standard on Solaris 10. - readLink=`which readlink` - if [ ! `expr "$readLink" : '\([^ ]*\)'` = "no" ]; then - if $darwin ; then - javaHome="`dirname \"$javaExecutable\"`" - javaExecutable="`cd \"$javaHome\" && pwd -P`/javac" - else - javaExecutable="`readlink -f \"$javaExecutable\"`" - fi - javaHome="`dirname \"$javaExecutable\"`" - javaHome=`expr "$javaHome" : '\(.*\)/bin'` - JAVA_HOME="$javaHome" - export JAVA_HOME - fi - fi -fi - -if [ -z "$JAVACMD" ] ; then - if [ -n "$JAVA_HOME" ] ; then - if [ -x "$JAVA_HOME/jre/sh/java" ] ; then - # IBM's JDK on AIX uses strange locations for the executables - JAVACMD="$JAVA_HOME/jre/sh/java" - else - JAVACMD="$JAVA_HOME/bin/java" - fi - else - JAVACMD="`which java`" - fi -fi - -if [ ! -x "$JAVACMD" ] ; then - echo "Error: JAVA_HOME is not defined correctly." >&2 - echo " We cannot execute $JAVACMD" >&2 - exit 1 -fi - -if [ -z "$JAVA_HOME" ] ; then - echo "Warning: JAVA_HOME environment variable is not set." -fi - -CLASSWORLDS_LAUNCHER=org.codehaus.plexus.classworlds.launcher.Launcher - -# traverses directory structure from process work directory to filesystem root -# first directory with .mvn subdirectory is considered project base directory -find_maven_basedir() { - - if [ -z "$1" ] - then - echo "Path not specified to find_maven_basedir" - return 1 - fi - - basedir="$1" - wdir="$1" - while [ "$wdir" != '/' ] ; do - if [ -d "$wdir"/.mvn ] ; then - basedir=$wdir - break - fi - # workaround for JBEAP-8937 (on Solaris 10/Sparc) - if [ -d "${wdir}" ]; then - wdir=`cd "$wdir/.."; pwd` - fi - # end of workaround - done - echo "${basedir}" -} - -# concatenates all lines of a file -concat_lines() { - if [ -f "$1" ]; then - echo "$(tr -s '\n' ' ' < "$1")" - fi -} - -BASE_DIR=`find_maven_basedir "$(pwd)"` -if [ -z "$BASE_DIR" ]; then - exit 1; -fi - -export MAVEN_PROJECTBASEDIR=${MAVEN_BASEDIR:-"$BASE_DIR"} -echo $MAVEN_PROJECTBASEDIR -MAVEN_OPTS="$(concat_lines "$MAVEN_PROJECTBASEDIR/.mvn/jvm.config") $MAVEN_OPTS" - -# For Cygwin, switch paths to Windows format before running java -if $cygwin; then - [ -n "$M2_HOME" ] && - M2_HOME=`cygpath --path --windows "$M2_HOME"` - [ -n "$JAVA_HOME" ] && - JAVA_HOME=`cygpath --path --windows "$JAVA_HOME"` - [ -n "$CLASSPATH" ] && - CLASSPATH=`cygpath --path --windows "$CLASSPATH"` - [ -n "$MAVEN_PROJECTBASEDIR" ] && - MAVEN_PROJECTBASEDIR=`cygpath --path --windows "$MAVEN_PROJECTBASEDIR"` -fi - -WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain - -exec "$JAVACMD" \ - $MAVEN_OPTS \ - -classpath "$MAVEN_PROJECTBASEDIR/.mvn/wrapper/maven-wrapper.jar" \ - "-Dmaven.home=${M2_HOME}" "-Dmaven.multiModuleProjectDirectory=${MAVEN_PROJECTBASEDIR}" \ - ${WRAPPER_LAUNCHER} $MAVEN_CONFIG "$@" diff --git a/function-samples/kstreams-word-count/mvnw.cmd b/function-samples/kstreams-word-count/mvnw.cmd deleted file mode 100644 index 019bd74..0000000 --- a/function-samples/kstreams-word-count/mvnw.cmd +++ /dev/null @@ -1,143 +0,0 @@ -@REM ---------------------------------------------------------------------------- -@REM Licensed to the Apache Software Foundation (ASF) under one -@REM or more contributor license agreements. See the NOTICE file -@REM distributed with this work for additional information -@REM regarding copyright ownership. The ASF licenses this file -@REM to you under the Apache License, Version 2.0 (the -@REM "License"); you may not use this file except in compliance -@REM with the License. You may obtain a copy of the License at -@REM -@REM http://www.apache.org/licenses/LICENSE-2.0 -@REM -@REM Unless required by applicable law or agreed to in writing, -@REM software distributed under the License is distributed on an -@REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -@REM KIND, either express or implied. See the License for the -@REM specific language governing permissions and limitations -@REM under the License. -@REM ---------------------------------------------------------------------------- - -@REM ---------------------------------------------------------------------------- -@REM Maven2 Start Up Batch script -@REM -@REM Required ENV vars: -@REM JAVA_HOME - location of a JDK home dir -@REM -@REM Optional ENV vars -@REM M2_HOME - location of maven2's installed home dir -@REM MAVEN_BATCH_ECHO - set to 'on' to enable the echoing of the batch commands -@REM MAVEN_BATCH_PAUSE - set to 'on' to wait for a key stroke before ending -@REM MAVEN_OPTS - parameters passed to the Java VM when running Maven -@REM e.g. to debug Maven itself, use -@REM set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000 -@REM MAVEN_SKIP_RC - flag to disable loading of mavenrc files -@REM ---------------------------------------------------------------------------- - -@REM Begin all REM lines with '@' in case MAVEN_BATCH_ECHO is 'on' -@echo off -@REM enable echoing my setting MAVEN_BATCH_ECHO to 'on' -@if "%MAVEN_BATCH_ECHO%" == "on" echo %MAVEN_BATCH_ECHO% - -@REM set %HOME% to equivalent of $HOME -if "%HOME%" == "" (set "HOME=%HOMEDRIVE%%HOMEPATH%") - -@REM Execute a user defined script before this one -if not "%MAVEN_SKIP_RC%" == "" goto skipRcPre -@REM check for pre script, once with legacy .bat ending and once with .cmd ending -if exist "%HOME%\mavenrc_pre.bat" call "%HOME%\mavenrc_pre.bat" -if exist "%HOME%\mavenrc_pre.cmd" call "%HOME%\mavenrc_pre.cmd" -:skipRcPre - -@setlocal - -set ERROR_CODE=0 - -@REM To isolate internal variables from possible post scripts, we use another setlocal -@setlocal - -@REM ==== START VALIDATION ==== -if not "%JAVA_HOME%" == "" goto OkJHome - -echo. -echo Error: JAVA_HOME not found in your environment. >&2 -echo Please set the JAVA_HOME variable in your environment to match the >&2 -echo location of your Java installation. >&2 -echo. -goto error - -:OkJHome -if exist "%JAVA_HOME%\bin\java.exe" goto init - -echo. -echo Error: JAVA_HOME is set to an invalid directory. >&2 -echo JAVA_HOME = "%JAVA_HOME%" >&2 -echo Please set the JAVA_HOME variable in your environment to match the >&2 -echo location of your Java installation. >&2 -echo. -goto error - -@REM ==== END VALIDATION ==== - -:init - -@REM Find the project base dir, i.e. the directory that contains the folder ".mvn". -@REM Fallback to current working directory if not found. - -set MAVEN_PROJECTBASEDIR=%MAVEN_BASEDIR% -IF NOT "%MAVEN_PROJECTBASEDIR%"=="" goto endDetectBaseDir - -set EXEC_DIR=%CD% -set WDIR=%EXEC_DIR% -:findBaseDir -IF EXIST "%WDIR%"\.mvn goto baseDirFound -cd .. -IF "%WDIR%"=="%CD%" goto baseDirNotFound -set WDIR=%CD% -goto findBaseDir - -:baseDirFound -set MAVEN_PROJECTBASEDIR=%WDIR% -cd "%EXEC_DIR%" -goto endDetectBaseDir - -:baseDirNotFound -set MAVEN_PROJECTBASEDIR=%EXEC_DIR% -cd "%EXEC_DIR%" - -:endDetectBaseDir - -IF NOT EXIST "%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config" goto endReadAdditionalConfig - -@setlocal EnableExtensions EnableDelayedExpansion -for /F "usebackq delims=" %%a in ("%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config") do set JVM_CONFIG_MAVEN_PROPS=!JVM_CONFIG_MAVEN_PROPS! %%a -@endlocal & set JVM_CONFIG_MAVEN_PROPS=%JVM_CONFIG_MAVEN_PROPS% - -:endReadAdditionalConfig - -SET MAVEN_JAVA_EXE="%JAVA_HOME%\bin\java.exe" - -set WRAPPER_JAR="%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.jar" -set WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain - -%MAVEN_JAVA_EXE% %JVM_CONFIG_MAVEN_PROPS% %MAVEN_OPTS% %MAVEN_DEBUG_OPTS% -classpath %WRAPPER_JAR% "-Dmaven.multiModuleProjectDirectory=%MAVEN_PROJECTBASEDIR%" %WRAPPER_LAUNCHER% %MAVEN_CONFIG% %* -if ERRORLEVEL 1 goto error -goto end - -:error -set ERROR_CODE=1 - -:end -@endlocal & set ERROR_CODE=%ERROR_CODE% - -if not "%MAVEN_SKIP_RC%" == "" goto skipRcPost -@REM check for post script, once with legacy .bat ending and once with .cmd ending -if exist "%HOME%\mavenrc_post.bat" call "%HOME%\mavenrc_post.bat" -if exist "%HOME%\mavenrc_post.cmd" call "%HOME%\mavenrc_post.cmd" -:skipRcPost - -@REM pause the script if MAVEN_BATCH_PAUSE is set to 'on' -if "%MAVEN_BATCH_PAUSE%" == "on" pause - -if "%MAVEN_TERMINATE_CMD%" == "on" exit %ERROR_CODE% - -exit /B %ERROR_CODE% diff --git a/function-samples/kstreams-word-count/pom.xml b/function-samples/kstreams-word-count/pom.xml deleted file mode 100644 index e0099b1..0000000 --- a/function-samples/kstreams-word-count/pom.xml +++ /dev/null @@ -1,60 +0,0 @@ - - - 4.0.0 - - - org.springframework.boot - spring-boot-starter-parent - 2.1.3.RELEASE - - - org.springframework.cloud.dataflow.samples - kstreams-word-count - 1.0.0.BUILD-SNAPSHOT - jar - - kstreams-word-count - Demo project for Kafka Streams word count sample - - - - - org.springframework.cloud.stream.app - app-starters-core-dependencies - 2.1.0.RELEASE - pom - import - - - - - - - - org.springframework.cloud - spring-cloud-stream-binder-kafka-streams - - - - org.springframework.cloud - spring-cloud-stream-binder-kafka - - - - - org.springframework.boot - spring-boot-starter-web - - - - - - - org.springframework.boot - spring-boot-maven-plugin - - - - - diff --git a/function-samples/kstreams-word-count/src/main/java/org/springframework/cloud/dataflow/samples/processor/KafkaStreamsWordCountApplication.java b/function-samples/kstreams-word-count/src/main/java/org/springframework/cloud/dataflow/samples/processor/KafkaStreamsWordCountApplication.java deleted file mode 100644 index cdca8df..0000000 --- a/function-samples/kstreams-word-count/src/main/java/org/springframework/cloud/dataflow/samples/processor/KafkaStreamsWordCountApplication.java +++ /dev/null @@ -1,110 +0,0 @@ -/* - * Copyright 2018-2019 the original author or authors. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * https://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.springframework.cloud.dataflow.samples.processor; - -import java.util.Arrays; -import java.util.Date; - -import org.apache.kafka.common.serialization.Serdes; -import org.apache.kafka.streams.KeyValue; -import org.apache.kafka.streams.kstream.KStream; -import org.apache.kafka.streams.kstream.Materialized; -import org.apache.kafka.streams.kstream.Serialized; -import org.apache.kafka.streams.kstream.TimeWindows; - -import org.springframework.boot.SpringApplication; -import org.springframework.boot.autoconfigure.SpringBootApplication; -import org.springframework.cloud.stream.annotation.EnableBinding; -import org.springframework.cloud.stream.annotation.StreamListener; -import org.springframework.cloud.stream.binder.kafka.streams.annotations.KafkaStreamsProcessor; -import org.springframework.messaging.handler.annotation.SendTo; - -@SpringBootApplication -public class KafkaStreamsWordCountApplication { - - public static void main(String[] args) { - SpringApplication.run(KafkaStreamsWordCountApplication.class, args); - } - - @EnableBinding(KafkaStreamsProcessor.class) - public static class WordCountProcessorApplication { - - @StreamListener("input") - @SendTo("output") - public KStream process(KStream input) { - - return input - .flatMapValues(value -> Arrays.asList(value.toLowerCase().split("\\W+"))) - .map((key, value) -> new KeyValue<>(value, value)) - .groupByKey(Serialized.with(Serdes.String(), Serdes.String())) - .windowedBy(TimeWindows.of(30000)) - .count(Materialized.as("WordCounts-1")) - .toStream() - .map((key, value) -> new KeyValue<>(null, new WordCount(key.key(), value, new Date(key.window().start()), new Date(key.window().end())))); - } - } - - static class WordCount { - - private String word; - - private long count; - - private Date start; - - private Date end; - - WordCount(String word, long count, Date start, Date end) { - this.word = word; - this.count = count; - this.start = start; - this.end = end; - } - - public String getWord() { - return word; - } - - public void setWord(String word) { - this.word = word; - } - - public long getCount() { - return count; - } - - public void setCount(long count) { - this.count = count; - } - - public Date getStart() { - return start; - } - - public void setStart(Date start) { - this.start = start; - } - - public Date getEnd() { - return end; - } - - public void setEnd(Date end) { - this.end = end; - } - } -} diff --git a/function-samples/kstreams-word-count/src/main/resources/application.yml b/function-samples/kstreams-word-count/src/main/resources/application.yml deleted file mode 100644 index b2326b5..0000000 --- a/function-samples/kstreams-word-count/src/main/resources/application.yml +++ /dev/null @@ -1,6 +0,0 @@ -spring.cloud.stream.kafka.streams: - binder.configuration: - commit.interval.ms: 1000 - default.key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde - default.value.serde: org.apache.kafka.common.serialization.Serdes$StringSerde - bindings.input.consumer.application-id: kstream-word-count-sample diff --git a/function-samples/pom.xml b/function-samples/pom.xml index a59042e..e170815 100644 --- a/function-samples/pom.xml +++ b/function-samples/pom.xml @@ -17,53 +17,4 @@ Pivotal Software, Inc. https://www.spring.io - - - spring - - - spring-snapshots - Spring Snapshots - https://repo.spring.io/libs-snapshot - - true - - - - spring-milestones - Spring Milestones - https://repo.spring.io/libs-milestone-local - - false - - - - spring-releases - Spring Releases - https://repo.spring.io/release - - false - - - - - - spring-snapshots - Spring Snapshots - https://repo.spring.io/libs-snapshot-local - - true - - - - spring-milestones - Spring Milestones - https://repo.spring.io/libs-milestone-local - - false - - - - - diff --git a/function-samples/uppercase-processor/pom.xml b/function-samples/uppercase-processor/pom.xml index c90196b..a86b077 100644 --- a/function-samples/uppercase-processor/pom.xml +++ b/function-samples/uppercase-processor/pom.xml @@ -69,4 +69,49 @@ + + + + spring-snapshots + Spring Snapshots + https://repo.spring.io/libs-snapshot + + true + + + + spring-milestones + Spring Milestones + https://repo.spring.io/libs-milestone-local + + false + + + + spring-releases + Spring Releases + https://repo.spring.io/release + + false + + + + + + spring-snapshots + Spring Snapshots + https://repo.spring.io/libs-snapshot-local + + true + + + + spring-milestones + Spring Milestones + https://repo.spring.io/libs-milestone-local + + false + + +