protected AvgAggregationBuilder regAvgA(String name, String field) {
        AvgAggregationBuilder builder = AggregationBuilders.avg(name).field(field);
        regA(builder);
        return builder;
    }

    protected MaxAggregationBuilder regMaxA(String name, String field) {
        MaxAggregationBuilder builder = AggregationBuilders.max(name).field(field);
        regA(builder);
        return builder;
    }

                return fields;
            }

            @Override
            public String[] getQueryAdditionalSearchFields(String... fields) {
                return fields;
            }

            @Override
            public String[] getQueryAdditionalFacetFields(String... fields) {
                return fields;
            }

            @Override

    }

    // Test annotation on field
    public void test_annotationOnField() throws Exception {
        final Field field = CustomSizeTest.class.getDeclaredField("testField");
        final CustomSize annotation = field.getAnnotation(CustomSize.class);

        assertNotNull("Annotation should be present on field", annotation);

import static org.mockito.Mockito.mockStatic;
import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;

import java.lang.reflect.Field;

import org.bouncycastle.asn1.ASN1ObjectIdentifier;
import org.ietf.jgss.GSSContext;
import org.ietf.jgss.GSSCredential;
import org.ietf.jgss.GSSException;
import org.ietf.jgss.GSSManager;

        byte[] header = buildHeader(NtStatus.NT_STATUS_BUFFER_OVERFLOW);

        // SrvPipePeekResponse expects at least 16 bytes (4 ints) output
        byte[] out = new byte[16];
        // leave all fields zero for simplicity

        byte[] body = buildIoctlResponseBody(Smb2IoctlRequest.FSCTL_PIPE_PEEK, new byte[16], 0, null, out.length, out, 0);
        byte[] packet = new byte[header.length + body.length];

            if (fieldSet.contains(CLUSTER_NAME)) {
                builder.field(CLUSTER_NAME, response.getClusterName());
            }
            if (fieldSet.contains(STATUS)) {
                builder.field(STATUS, response.getStatus().name().toLowerCase(Locale.ROOT));
            }
            if (fieldSet.contains(TIMED_OUT)) {
                builder.field(TIMED_OUT, response.isTimedOut());
            }

        }
    }

    // Helper method to set private dialectIndex field using reflection
    private void setDialectIndex(SmbComNegotiateResponse response, int dialectIndex) {
        try {
            Field field = response.getClass().getDeclaredField("dialectIndex");
            field.setAccessible(true);
            field.set(response, dialectIndex);
        } catch (Exception e) {

func (z *ActiveWorkerStat) DecodeMsg(dc *msgp.Reader) (err error) {
	var field []byte
	_ = field
	var zb0001 uint32
	zb0001, err = dc.ReadMapHeader()
	if err != nil {
		err = msgp.WrapError(err)
		return
	}
	for zb0001 > 0 {
		zb0001--
		field, err = dc.ReadMapKeyPtr()
		if err != nil {
			err = msgp.WrapError(err)
			return
		}
		switch msgp.UnsafeString(field) {
		case "Curr":
			z.Curr, err = dc.ReadInt()

                return baseConfig.getQueryAdditionalCacheResponseFields(fields);
            }

            @Override
            public String[] getQueryAdditionalHighlightedFields(String... fields) {
                return baseConfig.getQueryAdditionalHighlightedFields(fields);
            }

            @Override
            public String[] getQueryAdditionalSearchFields(String... fields) {

	// Columns
	AddColumn(dst interface{}, field string) error
	DropColumn(dst interface{}, field string) error
	AlterColumn(dst interface{}, field string) error
	MigrateColumn(dst interface{}, field *schema.Field, columnType ColumnType) error
	// MigrateColumnUnique migrate column's UNIQUE constraint, it's part of MigrateColumn.
	MigrateColumnUnique(dst interface{}, field *schema.Field, columnType ColumnType) error