Skip to content

map streamer

Codecov / codecov/patch succeeded Nov 6, 2024 in 1s

No report found to compare against

View this Pull Request on Codecov

No report found to compare against

Annotations

Check warning on line 66 in src/main/java/io/numaproj/numaflow/batchmapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/batchmapper/Server.java#L66 

Added line #L66 was not covered by tests

Check warning on line 70 in src/main/java/io/numaproj/numaflow/batchmapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/batchmapper/Server.java#L70 

Added line #L70 was not covered by tests

Check warning on line 89 in src/main/java/io/numaproj/numaflow/batchmapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/batchmapper/Server.java#L88-L89 

Added lines #L88 - L89 were not covered by tests

Check warning on line 99 in src/main/java/io/numaproj/numaflow/batchmapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/batchmapper/Server.java#L99 

Added line #L99 was not covered by tests

Check warning on line 111 in src/main/java/io/numaproj/numaflow/batchmapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/batchmapper/Server.java#L109-L111 

Added lines #L109 - L111 were not covered by tests

Check warning on line 125 in src/main/java/io/numaproj/numaflow/batchmapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/batchmapper/Server.java#L125 

Added line #L125 was not covered by tests

Check warning on line 127 in src/main/java/io/numaproj/numaflow/batchmapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/batchmapper/Server.java#L127 

Added line #L127 was not covered by tests

Check warning on line 113 in src/main/java/io/numaproj/numaflow/batchmapper/Service.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/batchmapper/Service.java#L111-L113 

Added lines #L111 - L113 were not covered by tests

Check warning on line 116 in src/main/java/io/numaproj/numaflow/batchmapper/Service.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/batchmapper/Service.java#L115-L116 

Added lines #L115 - L116 were not covered by tests

Check warning on line 71 in src/main/java/io/numaproj/numaflow/mapper/MapSupervisorActor.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapSupervisorActor.java#L70-L71 

Added lines #L70 - L71 were not covered by tests

Check warning on line 122 in src/main/java/io/numaproj/numaflow/mapper/MapSupervisorActor.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapSupervisorActor.java#L121-L122 

Added lines #L121 - L122 were not covered by tests

Check warning on line 133 in src/main/java/io/numaproj/numaflow/mapper/MapSupervisorActor.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/MapSupervisorActor.java#L132-L133 

Added lines #L132 - L133 were not covered by tests

Check warning on line 70 in src/main/java/io/numaproj/numaflow/mapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/Server.java#L70 

Added line #L70 was not covered by tests

Check warning on line 74 in src/main/java/io/numaproj/numaflow/mapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/Server.java#L74 

Added line #L74 was not covered by tests

Check warning on line 95 in src/main/java/io/numaproj/numaflow/mapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/Server.java#L94-L95 

Added lines #L94 - L95 were not covered by tests

Check warning on line 105 in src/main/java/io/numaproj/numaflow/mapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/Server.java#L105 

Added line #L105 was not covered by tests

Check warning on line 117 in src/main/java/io/numaproj/numaflow/mapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/Server.java#L115-L117 

Added lines #L115 - L117 were not covered by tests

Check warning on line 131 in src/main/java/io/numaproj/numaflow/mapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/Server.java#L131 

Added line #L131 was not covered by tests

Check warning on line 133 in src/main/java/io/numaproj/numaflow/mapper/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapper/Server.java#L133 

Added line #L133 was not covered by tests

Check warning on line 66 in src/main/java/io/numaproj/numaflow/mapstreamer/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapstreamer/Server.java#L66 

Added line #L66 was not covered by tests

Check warning on line 70 in src/main/java/io/numaproj/numaflow/mapstreamer/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapstreamer/Server.java#L70 

Added line #L70 was not covered by tests

Check warning on line 89 in src/main/java/io/numaproj/numaflow/mapstreamer/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapstreamer/Server.java#L88-L89 

Added lines #L88 - L89 were not covered by tests

Check warning on line 99 in src/main/java/io/numaproj/numaflow/mapstreamer/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapstreamer/Server.java#L99 

Added line #L99 was not covered by tests

Check warning on line 111 in src/main/java/io/numaproj/numaflow/mapstreamer/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapstreamer/Server.java#L109-L111 

Added lines #L109 - L111 were not covered by tests

Check warning on line 125 in src/main/java/io/numaproj/numaflow/mapstreamer/Server.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapstreamer/Server.java#L125 

Added line #L125 was not covered by tests
View more details on Codecov