miko-code
miko-code
/ docker-compose.yml
Last active
September 30, 2020 10:28
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| version: '3.7' | |
| services: | |
| postgres: | |
| image: postgres | |
| restart: unless-stopped | |
| environment: | |
| - POSTGRES_PASSWORD=root | |
| - POSTGRES_USER=root | |
| - POSTGRES_DB=ttn_lorawan | |
| volumes: |
miko-code
/ ttn-lw-stack-docker.yml
Last active
September 30, 2020 10:29
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| is: | |
| email: | |
| sender-name: The Things Stack | |
| sender-address: noreply@localhost | |
| network: | |
| name: The Things Stack | |
| console-url: 'https://thethings.centralus.cloudapp.azure.com/console' | |
| identity-server-url: 'https://thethings.centralus.cloudapp.azure.com/oauth' | |
| oauth: | |
| ui: |
miko-code
/ Autotel.json
Last active
December 25, 2019 09:30
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| { | |
| "swagger": "2.0", | |
| "info": { | |
| "title": "Safer Place Autotel", | |
| "version": "1.0" | |
| }, | |
| "paths": { | |
| "/parkingstatus": { | |
| "post": { | |
| "summary": "Update Parking status", |
miko-code
/ Autotel.yml
Created
December 25, 2019 08:58
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| openapi: '3.0.2' | |
| info: | |
| title: Safer Place Autotel | |
| version: '1.0' | |
| servers: | |
| - url: https://integapi.tlv.gov.il/v1/ | |
| paths: | |
| /parkingstatus: | |
| post: | |
| summary: Update Parking status |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 2018-06-04 05:20:56,984 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -------------------------------------------------------------------------------- | |
| 2018-06-04 05:20:56,985 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Starting StandaloneSessionClusterEntrypoint (Version: 1.5.0, Rev:c61b108, Date:24.05.2018 @ 14:54:44 UTC) | |
| 2018-06-04 05:20:56,985 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - OS current user: beam1 | |
| 2018-06-04 05:20:57,041 DEBUG org.apache.hadoop.metrics2.lib.MutableMetricsFactory - field org.apache.hadoop.metrics2.lib.MutableRate org.apache.hadoop.security.UserGroupInformation$UgiMetrics.loginSuccess with annotation @org.apache.hadoop.metrics2.annotation.Metric(about=, sampleName=Ops, always=false, type=DEFAULT, valueName=Time, value=[Rate of successful kerberos logins and latency (milliseconds)]) | |
| 2018-06-04 05:20:57,049 DEBUG org.apache.hadoop.metrics2.lib.MutableMetricsFactory - field org.apache.had |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 2018-05-31 11:56:22,953 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -------------------------------------------------------------------------------- | |
| 2018-05-31 11:56:22,954 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Starting StandaloneSessionClusterEntrypoint (Version: 1.5.0, Rev:c61b108, Date:24.05.2018 @ 14:54:44 UTC) | |
| 2018-05-31 11:56:22,954 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - OS current user: beam1 | |
| 2018-05-31 11:56:23,382 WARN org.apache.hadoop.util.NativeCodeLoader - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable | |
| 2018-05-31 11:56:23,448 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Current Hadoop/Kerberos user: beam1 | |
| 2018-05-31 11:56:23,448 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - JVM: OpenJDK 64-Bit Server VM - Oracle Corporation - 1.8/25.171-b11 | |
| 2018-05-31 11:56:23,448 INFO org.apache |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package org.tlv.integration; | |
| import org.apache.commons.dbutils.*; | |
| import org.apache.commons.dbutils.handlers.BeanHandler; | |
| import org.apache.flink.api.common.state.MapState; | |
| import org.apache.flink.api.common.state.MapStateDescriptor; | |
| import org.apache.flink.api.java.tuple.Tuple2; | |
| import org.apache.flink.configuration.Configuration; | |
| import org.apache.flink.streaming.api.functions.ProcessFunction; | |
| import org.apache.flink.streaming.api.functions.async.ResultFuture; |
This file has been truncated, but you can view the full file.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 2018-04-08 03:04:08,309 INFO org.apache.flink.runtime.jobmanager.JobManager - -------------------------------------------------------------------------------- | |
| 2018-04-08 03:04:08,310 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting JobManager (Version: 1.4.2, Rev:04e4c85, Date:28.02.2018 @ 12:53:14 UTC) | |
| 2018-04-08 03:04:08,311 INFO org.apache.flink.runtime.jobmanager.JobManager - OS current user: beam1 | |
| 2018-04-08 03:04:08,753 WARN org.apache.hadoop.util.NativeCodeLoader - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable | |
| 2018-04-08 03:04:08,875 INFO org.apache.flink.runtime.jobmanager.JobManager - Current Hadoop/Kerberos user: beam1 | |
| 2018-04-08 03:04:08,875 INFO org.apache.flink.runtime.jobmanager.JobManager - JVM: OpenJDK 64-Bit Server VM - Oracle Corporation - 1.8/25.151-b12 | |
| 2018-04-08 03:04:08,875 INFO org.apache.flink.runtime.jobmanage |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| =========================== Starting metrics report =========================== | |
| -- Counters ------------------------------------------------------------------- | |
| beam2.taskmanager.41377b81d8cd831da3e380ed59696801.Flink Streaming esb correlate msg.Source: Custom Source.0.numBytesInRemote: 0 | |
| beam2.taskmanager.41377b81d8cd831da3e380ed59696801.Flink Streaming esb correlate msg.TriggerWindow(GlobalWindows(), ListStateDescriptor{serializer=org.apache.flink.a.0.numRecordsIn: 1590 | |
| beam2.taskmanager.41377b81d8cd831da3e380ed59696801.Flink Streaming esb correlate msg.TriggerWindow(GlobalWindows(), ListStateDescriptor{serializer=org.apache.flink.api.common.typeutils.base.ListSerializer@15b09c51}, org.tlv.esb.EsbElk$EventTrigger@2e062ce6, org.tlv.esb.EsbElk$EsbTraceEvictor@56bd6f84, WindowedStream.apply(WindowedStream.java:1061)) -> Sink: Unnamed.0.numBytesInRemote: 0 | |
| beam2.taskmanager.41377b81d8cd831da3e380ed59696801.Flink Streaming esb correlate msg.Source: Custom Source.0.numRecordsOut: 1590 | |
| beam2.taskmanager.41377b81d8 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package org.tlv.esb; | |
| import org.apache.flink.api.common.functions.RuntimeContext; | |
| import org.apache.flink.api.common.restartstrategy.RestartStrategies; | |
| import org.apache.flink.api.common.time.Time; | |
| import org.apache.flink.api.java.functions.KeySelector; | |
| import org.apache.flink.streaming.api.datastream.DataStream; | |
| import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator; | |
| import org.apache.flink.streaming.api.environment.StreamContextEnvironment; | |
| import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; |
NewerOlder