Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -62,49 +62,45 @@ public List<LineError> lineErrors() {
}

/**
* Represents one failed line from a partial write response.
*/
public static final class LineError {

private final Integer lineNumber;
private final String errorMessage;
private final String originalLine;

/**
* @param lineNumber line number in the write payload; may be null if not provided by server
* @param errorMessage line-level error message
* @param originalLine original line protocol row; may be null if not provided by server
* Represents one failed line from a partial write response.
*/
public LineError(@Nullable final Integer lineNumber,
@Nonnull final String errorMessage,
@Nullable final String originalLine) {
this.lineNumber = lineNumber;
this.errorMessage = errorMessage;
this.originalLine = originalLine;
}
public record LineError(Integer lineNumber, String errorMessage, String originalLine) {

Comment on lines 64 to 68
/**
* @return line number or null if server didn't provide it
*/
@Nullable
public Integer lineNumber() {
return lineNumber;
}
/**
* @param lineNumber line number in the write payload; may be null if not provided by server
* @param errorMessage line-level error message
* @param originalLine original line protocol row; may be null if not provided by server
*/
public LineError(@Nullable final Integer lineNumber,
@Nonnull final String errorMessage,
@Nullable final String originalLine) {
Comment thread
NguyenHoangSon96 marked this conversation as resolved.
this.lineNumber = lineNumber;
this.errorMessage = errorMessage;
this.originalLine = originalLine;
}

/**
* @return line-level error message
*/
@Nonnull
public String errorMessage() {
return errorMessage;
}
/**
* @return line number or null if server didn't provide it
*/
@Nullable
public Integer lineNumber() {
return lineNumber;
}

/**
* @return original line protocol row or null if server didn't provide it
*/
@Nullable
public String originalLine() {
return originalLine;
/**
* @return line-level error message
*/
@Nullable
public String errorMessage() {
return errorMessage;
}

/**
* @return original line protocol row or null if server didn't provide it
*/
@Nullable
public String originalLine() {
return originalLine;
}
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -384,7 +384,7 @@ private <T> void writeData(@Nonnull final List<T> data, @Nonnull final WriteOpti
headers.putAll(options.headersSafe());

try {
restClient.request(path, HttpMethod.POST, body, queryParams, headers);
restClient.request(path, HttpMethod.POST, body, queryParams, headers, acceptPartial, useV2Api);
} catch (InfluxDBApiHttpException e) {
if (e.statusCode() == HttpResponseStatus.METHOD_NOT_ALLOWED.code()) {
if (useV2Api && "api/v2/write".equals(path)) {
Expand Down
Loading
Loading