Skip to content

Commit

Permalink
Fix javadoc errors
Browse files Browse the repository at this point in the history
Signed-off-by: Rishabh Maurya <[email protected]>
  • Loading branch information
rishabhmaurya committed Feb 10, 2025
1 parent 2714a04 commit 8ad89da
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -169,7 +169,7 @@ boolean isStale() {
* @param nodeId The ID of the node this holder belongs to
* @param reason The reason for closing
*/
public void close(String nodeId, String reason) {
void close(String nodeId, String reason) {
try {
if (flightClient != null) {
flightClient.close();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -52,8 +52,8 @@ public class FlightStreamManager implements StreamManager {
/**
* Holds a StreamProducer along with its metadata and resources
*/
public record StreamProducerHolder(StreamProducer<VectorSchemaRoot, BufferAllocator> producer, BufferAllocator allocator,
long creationTime, SetOnce<VectorSchemaRoot> root) {
record StreamProducerHolder(StreamProducer<VectorSchemaRoot, BufferAllocator> producer, BufferAllocator allocator, long creationTime,
SetOnce<VectorSchemaRoot> root) {
public StreamProducerHolder {
Objects.requireNonNull(producer, "StreamProducer cannot be null");
Objects.requireNonNull(allocator, "BufferAllocator cannot be null");
Expand Down

0 comments on commit 8ad89da

Please sign in to comment.