wtanaka/streaming issues and pull requests

#109 - Fix javadoc warnings

Pull Request - State: closed - Opened by wtanaka about 7 years ago - 1 comment

#108 - Allow Monotonic to use Top.Largest/Top.Smallest

Pull Request - State: closed - Opened by wtanaka about 7 years ago - 2 comments

#107 - ReifyTimestampAndWindow transform

Pull Request - State: closed - Opened by wtanaka about 7 years ago - 1 comment

#106 - Monotonic transform drops non-monotonic elements

Pull Request - State: closed - Opened by wtanaka about 7 years ago - 2 comments

#105 - FlattenKV utilities for PCollection<KV<K, Iterable<V>>>

Pull Request - State: closed - Opened by wtanaka about 7 years ago - 1 comment

#104 - Test of converting a PCollection to a List

Pull Request - State: closed - Opened by wtanaka about 7 years ago - 1 comment

#103 - Use MapElements.into

Pull Request - State: closed - Opened by wtanaka about 7 years ago - 1 comment

#102 - Increase code coverage

Pull Request - State: closed - Opened by wtanaka about 7 years ago - 1 comment

#101 - Create SlidingWc; StreamingWc outputs to stdout

Pull Request - State: closed - Opened by wtanaka about 7 years ago - 2 comments

#100 - Switch to image w/python2 installed

Pull Request - State: closed - Opened by wtanaka about 7 years ago - 1 comment

#99 - Use docker image with Java/Zookeeper already installed

Pull Request - State: closed - Opened by wtanaka about 7 years ago - 1 comment

#98 - Download galaxy roles in parallel

Pull Request - State: closed - Opened by wtanaka about 7 years ago - 1 comment

#97 - Flink 1.3.2

Pull Request - State: open - Opened by wtanaka about 7 years ago - 2 comments

#96 - Remove android dependency

Pull Request - State: closed - Opened by wtanaka about 7 years ago - 1 comment

#95 - Switch from log4j to slf4j

Pull Request - State: closed - Opened by wtanaka about 7 years ago - 1 comment

#94 - Add extra StreamIOTest

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 1 comment

#93 - Add javadoc comments

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 1 comment

#92 - Workaround android studio ambiguous method call error

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 1 comment

#91 - Add more tests

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 1 comment

#90 - Calculate percentage of elements matching predicate

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 1 comment

#89 - Make LoggingIO pass the input through to the output

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 1 comment

#88 - Add PTransform that terminates into PDone

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 1 comment

#87 - Allow composing Comparator and SerializableFunction

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 1 comment

#86 - Add helper functions for function composition

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 1 comment

#85 - Test for InvalidWindows

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 1 comment

#84 - Extract helper function tv() to create TimestampedValue

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 1 comment

#83 - Test StreamingWc with a pause in the middle

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 1 comment

#82 - IteratorIO

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 1 comment

#81 - Remove debug output

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 1 comment

#80 - Make unit test more deterministic

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 1 comment

#79 - Consolidate Stdout/Stdin into StreamIO

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 1 comment

#78 - Add to code coverage

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 1 comment

#77 - Sort updates

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 1 comment

#76 - Disable codecov patch commit status

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 1 comment

#75 - Beam 2.0.0

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 1 comment

#74 - Create StdoutIO to hide StdoutSink

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 1 comment

#73 - Make methods public

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 1 comment

#72 - Build javadocs as a part of testing

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 1 comment

#71 - Syntactical sugar for combine, order by, and limit

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#70 - Serializable Comparators that operate on KV

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 1 comment

#69 - Code to test Coder behavior

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 1 comment

#68 - Add some test code

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 1 comment

#67 - Add badges to README.md

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#66 - Upload reports to codecov

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 1 comment

#65 - Utility class to chain two PTransform sequentially

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#64 - Add watermarks and event time to StdinIO

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#63 - Move ByteArrayToString into transforms

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#62 - Add PaneInfo and event time output

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#61 - Bounded source of byte arrays

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#60 - Return a non-null CheckpointMark

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#59 - Merge StdinBoundedSource and StdinUnboundedSource

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#58 - Fix IllegalStateException when running tests in IntelliJ

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#57 - Add test coverage for Cat.main

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#56 - Remove unnecessary subclass

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#55 - Reduce access

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#54 - Switch to PCollection<byte[]>

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#53 - Code with samples of Triggering

Pull Request - State: closed - Opened by wtanaka over 7 years ago - 2 comments

#52 - Test WindowingStrategy behavior

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#51 - Add comment to Sort

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#50 - Automatically close and release sonatype

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#49 - Upload releases to Maven Central

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#48 - Add example code to top of Nl

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#47 - Turn on mavenCentralSync

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#46 - Ran travis command line

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#45 - Add scm section for Maven Central

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#44 - Add maven configuration

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#43 - Fix more warnings

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#42 - Fix some warnings, remove StreamIO

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#41 - Move StdinUnboundedReader inside StdinUnboundedSource

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#40 - Add source jar and javadoc jar

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#39 - git fetch --unshallow

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#38 - Turn on GPG signing

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#37 - Automatically publish on bintray

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#36 - version badge

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#35 - Deploy to bintray from TravisCI

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#34 - Cat and Nl, partial implementation

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#33 - Add environment variables

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#32 - Source for System.in

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#31 - Add comment

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#30 - sort

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#29 - Actually run pipelines in StreamIOTest

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#28 - Add shadow plugin

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#27 - cover StreamIO.Read constructor

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#26 - Increase coverage requirement

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#25 - nl

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#24 - Remove unnecessary cast

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#23 - Unit test for Cat

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#22 - Remove unnecessary explicit constructor

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#21 - Remove empty methods

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#20 - Convert lambda to method reference

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#19 - Add serialVersionUID

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#18 - Bump up code coverage

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#17 - Switch public to private

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#16 - LoggingIO PTransform

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#15 - Remove ruby matrix from tests

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#14 - Add test coverage verification

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#13 - StringValueOf PTransform

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#12 - Create skeletons for Cat and Nl

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#11 - Create StreamIO.Write.Bound

Pull Request - State: closed - Opened by wtanaka over 7 years ago

#10 - Switch to String for now to utilize StreamTokenizer

Pull Request - State: closed - Opened by wtanaka over 7 years ago

GitHub / wtanaka/streaming issues and pull requests